config <- ruut::get_config()
config
config$dbname
names(config)
names(config) %in% c("dbname","host","port","user","password")
names(config)
c("dbname","host","port","user","password") %in% names(config)
all(c("dbname","host","port","user","password") %in% names(config))
styler:::style_active_file()
RPostgreSQL::PostgreSQL()
config <- ruut::get_config()
try(conn <- DBI::dbConnect(RPostgreSQL::PostgreSQL(),
dbname = config$dbname, host = config$host,
user = config$user, password = config$password,
port = config$port
))
(
conn
)
db_connect <- function(conf = NULL) {
if (is.null(conf)) {
config <- ruut::get_config()
} else {
config <- conf
}
if (all(c("dbname", "host", "port", "user", "password") %in% names(config))) {
try(conn <- DBI::dbConnect(RPostgreSQL::PostgreSQL(),
dbname = config$dbname, host = config$host,
user = config$user, password = config$password,
port = config$port
))
} else {
print("Andmebaasiga \U00FChendamise parameetrid puudulikud. Palun kontrolli konfiguratsiooni faili.")
return()
}
## Andmebaasiga ühenduse kontroll
if (exists("conn") && !inherits(conn, "try-error")) {
print("Connection exist")
} else {
print("Connection error")
}
}
conn <- DBI::dbConnect(RPostgreSQL::PostgreSQL(),
dbname = config$dbname, host = config$host,
user = config$user, password = config$password,
port = config$port
)
conn <- DBI::dbConnect(RPostgreSQL::PostgreSQL(),
dbname = config$dbname, host = config$host,
user = config$user, password = config$password,
port = config$port
)
conn <- DBI::dbConnect(RPostgreSQL::PostgreSQL(),
dbname = config$dbname, host = config$host,
user = config$user, password = config$password,
port = config$port
)
config <- ruut::get_config()
config
conn <- DBI::dbConnect(RPostgreSQL::PostgreSQL(),
dbname = config$dbname, host = config$host,
user = config$user, password = config$password,
port = config$port
)
conn
## Andmebaasiga ühenduse kontroll
if (exists("conn") && !inherits(conn, "try-error")) {
print("Connection exist")
} else {
print("Connection error")
}
styler:::style_active_file()
library(ruut)
ruut::dbconnect()
library(ruut)
ruut::pk_bbox()
ruut::cat_function()
ruut::get_config()
source("R/db_connect.R")
conn <- db_connect()
conn
source("./R/db_connect.R")
source("./R/db_connect.R")
conn <- db_connect()
conn
source("db_connect.R")
styler:::style_active_file()
ruut::cat_function()
print(file.exists(system.file(c("db_connect.R"), package = "ruut")))
print(file.exists(system.file(c("db_connect.R"), package = "ruut")))
ruut::cat_function()
library(ruut)
ruut::cat_function()
library(ruut)
ruut::cat_function()
print(file.exists(system.file(c("db_connect.R"), package = "ruut")))
print(file.exists(system.file(c("R","db_connect.R"), package = "ruut")))
library(ruut)
ruut::cat_function()
ruut::cat_function()
styler:::style_active_file()
library(ruut)
ruut::cat_function()
paste0(getwd(),"/R/db_connect.R")
file.exists(paste0(getwd(),"/R/db_connect.R"))
library(ruut)
ruut::cat_function()
ruut::cat_function()
library(ruut)
ruut::cat_function()
styler:::style_active_file()
library(ruut)
ruut::cat_function()
db_connect <- function(conf = NULL) {
if (is.null(conf)) {
config <- ruut::get_config()
} else {
config <- conf
}
if (all(c("dbname", "host", "port", "user", "password") %in% names(config))) {
try(conn <- DBI::dbConnect(RPostgreSQL::PostgreSQL(),
dbname = config$dbname, host = config$host,
user = config$user, password = config$password,
port = config$port
))
} else {
conn <- NULL
print("Andmebaasiga \U00FChendamise parameetrid puudulikud. Palun kontrolli konfiguratsiooni faili.")
return()
}
## Andmebaasiga ühenduse kontroll
if (exists("conn") && !inherits(conn, "try-error")) {
print("Connection exist")
} else {
print("Connection error")
}
}
db_connect()
db_connect(conf = conf)
config <- ruut::get_config()
db_connect(conf = config)
db_connect(conf = c("3"))
conn
dbDisconnect(conn)
dbDisconnect(conn)
conn
library(ruut)
db_connect()
xxx <- db_connect()
xxx
library(ruut)
xxx <- db_connect()
db_connect()
library(ruut)
source(paste0(getwd(),"/R/db_connect.R"))
conn <- db_connect()
conn
library(ruut)
source(paste0(getwd(),"/R/db_connect.R"))
conn <- db_connect()
styler:::style_active_file()
get_config <- function(conf = NULL) {
if (is.null(conf)) {
config <- rjson::fromJSON(file = system.file("extdata", "config.json", package = "ruut"))
}
else {
config <- conf
}
return(config)
}
get_config
get_config()
styler:::style_active_file()
styler:::style_active_file()
styler:::style_active_file()
library(ruut)
library(ruut)
qgis_algorithm_search_by_word(str = "bound")
algorithm <- "native:boundingboxes"
## Read help!!!
cat(qgis_show_help(algorithm = algorithm))
# Run algorithm.
library(ruut)
library(ruut)
source(paste0(getwd(),"/R/db_connect.R"))
conn <- db_connect()
all_schemas <- DBI::dbGetQuery(conn, "SELECT SCHEMA_NAME FROM INFORMATION_SCHEMA.SCHEMATA")
all_schemas
db_all_schemas <- function() {
source(paste0(getwd(),"/R/db_connect.R"))
conn <- db_connect()
all_schemas <- DBI::dbGetQuery(conn, "SELECT SCHEMA_NAME FROM INFORMATION_SCHEMA.SCHEMATA")
all_schemas$schema_name
}
db_all_schemas()
db_is_shema_exist <- function(schema = NULL) {
if(schema %in% db_all_schemas()) return(TRUE) else return(FALSE)
}
db_is_shema_exist("xxxx")
aaa <- db_is_shema_exist("xxxx")
aaa <- db_is_shema_exist("x_matsalu")
aaa <- db_is_shema_exist("x_matsalu")
schema = "x_matsalu"
schema %in% db_all_schemas()
db_all_schemas()
aaa <- db_is_shema_exist(schema = "x_matsalu")
aaa
aaa <- db_is_shema_exist(schema = "sx_matsalu")
aaa <- db_is_shema_exist(schema = "sx_matsalu")
aaa <- db_is_shema_exist(schema = "sx_matsalu")
db_is_shema_exist <- function(schema = NULL) {
if(schema %in% db_all_schemas())
return(TRUE)
else
return(FALSE)
}
aaa <- db_is_shema_exist(schema = "sx_matsalu")
aaa <- db_is_shema_exist(schema = "sx_matsalu")
aaa
aaa <- db_is_shema_exist(schema = "x_matsalu")
aaa <- db_is_shema_exist(schema = "x_matsalu")
DBI::dbDisconnect(conn)
DBI::dbDisconnect(conn)
DBI::dbDisconnect(conn)
aaa <- db_is_shema_exist(schema = "x_matsalu")
aaa <- db_is_shema_exist(schema = "x_matsalu")
aaa <- db_is_shema_exist(schema = "x_matsalu")
aaa <- db_is_shema_exist(schema = "x_matsalu")
db_is_shema_exist(schema = "x_matsalu")
DBI::dbDisconnect(conn)
DBI::dbDisconnect(conn)
DBI::dbDisconnect(conn)
DBI::dbDisconnect(conn)
DBI::dbDisconnect(conn)
DBI::dbDisconnect(conn)
db_is_shema_exist(schema = "x_matsalu")
conn <- db_connect()
all_schemas <- DBI::dbGetQuery(conn, "SELECT SCHEMA_NAME FROM INFORMATION_SCHEMA.SCHEMATA")
all_schemas$schema_name
db_all_schemas <- function() {
source(paste0(getwd(),"/R/db_connect.R"))
conn <- db_connect()
all_schemas <- DBI::dbGetQuery(conn, "SELECT SCHEMA_NAME FROM INFORMATION_SCHEMA.SCHEMATA")
return (all_schemas$schema_name)
}
db_all_schemas()
db_all_schemas()
db_all_schemas()
db_all_schemas()
source(paste0(getwd(),"/R/db_connect.R"))
conn <- db_connect()
source(paste0(getwd(),"/R/db_connect.R"))
conn <- db_connect()
source(paste0(getwd(),"/R/db_connect.R"))
conn <- db_connect()
db_all_schemas <- function() {
source(paste0(getwd(),"/R/db_connect.R"))
conn <- db_connect()
all_schemas <- DBI::dbGetQuery(conn, "SELECT SCHEMA_NAME FROM INFORMATION_SCHEMA.SCHEMATA")
return (all_schemas$schema_name)
}
# db_all_schemas()
db_is_shema_exist <- function(schema = NULL) {
if(schema %in% db_all_schemas())
return(TRUE)
else
return(FALSE)
}
DBI::dbDisconnect(conn)
conn <- db_connect()
conn <- db_connect()
conn <- db_connect()
library(ruut)
conn <- db_connect()
source(paste0(getwd(),"/R/db_connect.R"))
conn <- db_connect()
all_schemas <- DBI::dbGetQuery(conn, "SELECT SCHEMA_NAME FROM INFORMATION_SCHEMA.SCHEMATA")
all_schemas
all_schemas$schema_name
library(ruut)
db_all_schemas <- function() {
source(paste0(getwd(),"/R/db_connect.R"))
conn <- db_connect()
all_schemas <- DBI::dbGetQuery(conn, "SELECT SCHEMA_NAME FROM INFORMATION_SCHEMA.SCHEMATA")
return (all_schemas$schema_name)
}
# db_all_schemas()
db_is_shema_exist <- function(schema = NULL) {
if(schema %in% db_all_schemas())
return(TRUE)
else
return(FALSE)
}
db_all_schemas()
db_is_shema_exist <- function(schema = NULL) {
if(schema %in% db_all_schemas())
return(TRUE)
else
return(FALSE)
}
aaa <- db_is_shema_exist(schema = "x_matsalu")
aaa <- db_is_shema_exist(schema = "x_matsalu")
aaa <- db_is_shema_exist(schema = "xx_matsalu")
schema = "xx_matsalu"
schema %in% db_all_schemas()
schema %in% db_all_schemas()
if(schema %in% db_all_schemas())
TRUE
else
FALSE
if(schema %in% db_all_schemas())
TRUE
else
FALSE
if(schema %in% db_all_schemas())
TRUE
if(schema %in% db_all_schemas())
TRUE
library(ruut)
db_all_schemas <- function() {
source(paste0(getwd(),"/R/db_connect.R"))
conn <- db_connect()
all_schemas <- DBI::dbGetQuery(conn, "SELECT SCHEMA_NAME FROM INFORMATION_SCHEMA.SCHEMATA")
return (all_schemas$schema_name)
}
db_all_schemas()
db_is_shema_exist <- function(schema = NULL) {
if(schema %in% db_all_schemas())
TRUE
else
FALSE
}
db_is_shema_exist(schema = "xx_matsalu")
db_is_shema_exist(schema = "x_matsalu")
db_is_shema_exist(schema = "x_matsalu")
db_create_new_schema <- function(conf) {
conn <- db_connect()
all_schemas <- DBI::dbGetQuery(conn,sprintf(
"-- DROP SCHEMA x_matsalu;
CREATE SCHEMA %s AUTHORIZATION %s;", conf$schema, conf$user))
}
db_create_new_schema(conf)
styler:::style_active_file()
db_create_new_schema <- function(conf) {
conn <- db_connect()
DBI::dbExecute(conn, sprintf(
"-- DROP SCHEMA x_matsalu;
CREATE SCHEMA %s AUTHORIZATION %s;", conf$schema, conf$user
))
}
conf <- ruut::get_config()
conf
db_create_new_schema <- function(conf) {
conn <- db_connect()
DBI::dbExecute(conn, sprintf(
"-- DROP SCHEMA x_matsalu;
CREATE SCHEMA %s AUTHORIZATION %s;", conf$schema, conf$user
))
}
db_create_new_schema(conf)
conf$schema <- "x_valga"
db_create_new_schema(conf)
source(paste0(getwd(), "/R/db_all_schemas"))
source(paste0(getwd(), "/R/db_all_schemas.R"))
paste0(getwd(), "/R/db_all_schemas.R")
source(paste0(getwd(), "/R/db_all_schemas.R"))
db_is_shema_exist(schema = "x_matsalu")
db_is_shema_exist(schema = "x_matsalu")
db_is_shema_exist(schema = "zx_matsalu")
styler:::style_active_file()
styler:::style_active_file()
db_create_new_schema <- function(conf) {
source(paste0(getwd(), "/R/db_is_shema_exist.R"))
if(db_is_shema_exist(schema)) {
conn <- db_connect()
DBI::dbExecute(conn, sprintf(
"-- DROP SCHEMA x_matsalu;
CREATE SCHEMA %s AUTHORIZATION %s;", conf$schema, conf$user
))
}
}
conf <- ruut::get_config()
conf$schema <- "x_valga"
db_create_new_schema(conf)
conf <- ruut::get_config()
conf$schema <- "x_valga1"
db_create_new_schema(conf)
conf <- ruut::get_config()
conf
conf$schema <- "x_valga1"
conf
db_create_new_schema(conf)
conf$schema
db_create_new_schema <- function(conf) {
source(paste0(getwd(), "/R/db_is_shema_exist.R"))
if(!db_is_shema_exist(conf$schema)) {
conn <- db_connect()
DBI::dbExecute(conn, sprintf(
"-- DROP SCHEMA x_matsalu;
CREATE SCHEMA %s AUTHORIZATION %s;", conf$schema, conf$user
))
}
}
conf <- ruut::get_config()
conf$schema <- "x_valga1"
db_create_new_schema(conf)
conf <- ruut::get_config()
conf$schema <- "x_valga1"
db_create_new_schema(conf)
library(ruut)
conf <- ruut::get_config()
conf
conf$schema <- "x_valga1"
db_create_new_schema(conf)
db_create_new_schema <- function(conf) {
source(paste0(getwd(), "/R/db_is_shema_exist.R"))
if(!db_is_shema_exist(conf$schema)) {
conn <- db_connect()
DBI::dbExecute(conn, sprintf(
"-- DROP SCHEMA x_matsalu;
CREATE SCHEMA %s AUTHORIZATION %s;", conf$schema, conf$user
))
}
}
db_create_new_schema(conf)
DBI::dbDisconnect(conn)
conf <- ruut::get_config()
conf$schema <- "x_valga1"
db_create_new_schema(conf)
conf <- ruut::get_config()
conf$schema <- "x_valga1"
db_create_new_schema(conf)
conf <- ruut::get_config()
conf$schema <- "x_valga"
db_create_new_schema(conf)
conf <- ruut::get_config()
conf$schema <- "x_valga"
db_create_new_schema(conf)
conf <- ruut::get_config()
conf$schema <- "x_valga"
db_create_new_schema(conf)
conf <- ruut::get_config()
conf$schema <- "x_valga"
db_create_new_schema(conf)
styler:::style_active_file()
library(ruut)
styler:::style_active_file()
library(ruut)
styler:::style_active_file()
library(ruut)
library(ruut)