.Rhistory 12 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451
  1. config <- ruut::get_config()
  2. config
  3. config$dbname
  4. names(config)
  5. names(config) %in% c("dbname","host","port","user","password")
  6. names(config)
  7. c("dbname","host","port","user","password") %in% names(config)
  8. all(c("dbname","host","port","user","password") %in% names(config))
  9. styler:::style_active_file()
  10. RPostgreSQL::PostgreSQL()
  11. config <- ruut::get_config()
  12. try(conn <- DBI::dbConnect(RPostgreSQL::PostgreSQL(),
  13. dbname = config$dbname, host = config$host,
  14. user = config$user, password = config$password,
  15. port = config$port
  16. ))
  17. (
  18. conn
  19. )
  20. db_connect <- function(conf = NULL) {
  21. if (is.null(conf)) {
  22. config <- ruut::get_config()
  23. } else {
  24. config <- conf
  25. }
  26. if (all(c("dbname", "host", "port", "user", "password") %in% names(config))) {
  27. try(conn <- DBI::dbConnect(RPostgreSQL::PostgreSQL(),
  28. dbname = config$dbname, host = config$host,
  29. user = config$user, password = config$password,
  30. port = config$port
  31. ))
  32. } else {
  33. print("Andmebaasiga \U00FChendamise parameetrid puudulikud. Palun kontrolli konfiguratsiooni faili.")
  34. return()
  35. }
  36. ## Andmebaasiga ühenduse kontroll
  37. if (exists("conn") && !inherits(conn, "try-error")) {
  38. print("Connection exist")
  39. } else {
  40. print("Connection error")
  41. }
  42. }
  43. conn <- DBI::dbConnect(RPostgreSQL::PostgreSQL(),
  44. dbname = config$dbname, host = config$host,
  45. user = config$user, password = config$password,
  46. port = config$port
  47. )
  48. conn <- DBI::dbConnect(RPostgreSQL::PostgreSQL(),
  49. dbname = config$dbname, host = config$host,
  50. user = config$user, password = config$password,
  51. port = config$port
  52. )
  53. conn <- DBI::dbConnect(RPostgreSQL::PostgreSQL(),
  54. dbname = config$dbname, host = config$host,
  55. user = config$user, password = config$password,
  56. port = config$port
  57. )
  58. config <- ruut::get_config()
  59. config
  60. conn <- DBI::dbConnect(RPostgreSQL::PostgreSQL(),
  61. dbname = config$dbname, host = config$host,
  62. user = config$user, password = config$password,
  63. port = config$port
  64. )
  65. conn
  66. ## Andmebaasiga ühenduse kontroll
  67. if (exists("conn") && !inherits(conn, "try-error")) {
  68. print("Connection exist")
  69. } else {
  70. print("Connection error")
  71. }
  72. styler:::style_active_file()
  73. library(ruut)
  74. ruut::dbconnect()
  75. library(ruut)
  76. ruut::pk_bbox()
  77. ruut::cat_function()
  78. ruut::get_config()
  79. source("R/db_connect.R")
  80. conn <- db_connect()
  81. conn
  82. source("./R/db_connect.R")
  83. source("./R/db_connect.R")
  84. conn <- db_connect()
  85. conn
  86. source("db_connect.R")
  87. styler:::style_active_file()
  88. ruut::cat_function()
  89. print(file.exists(system.file(c("db_connect.R"), package = "ruut")))
  90. print(file.exists(system.file(c("db_connect.R"), package = "ruut")))
  91. ruut::cat_function()
  92. library(ruut)
  93. ruut::cat_function()
  94. library(ruut)
  95. ruut::cat_function()
  96. print(file.exists(system.file(c("db_connect.R"), package = "ruut")))
  97. print(file.exists(system.file(c("R","db_connect.R"), package = "ruut")))
  98. library(ruut)
  99. ruut::cat_function()
  100. ruut::cat_function()
  101. styler:::style_active_file()
  102. library(ruut)
  103. ruut::cat_function()
  104. paste0(getwd(),"/R/db_connect.R")
  105. file.exists(paste0(getwd(),"/R/db_connect.R"))
  106. library(ruut)
  107. ruut::cat_function()
  108. ruut::cat_function()
  109. library(ruut)
  110. ruut::cat_function()
  111. styler:::style_active_file()
  112. library(ruut)
  113. ruut::cat_function()
  114. db_connect <- function(conf = NULL) {
  115. if (is.null(conf)) {
  116. config <- ruut::get_config()
  117. } else {
  118. config <- conf
  119. }
  120. if (all(c("dbname", "host", "port", "user", "password") %in% names(config))) {
  121. try(conn <- DBI::dbConnect(RPostgreSQL::PostgreSQL(),
  122. dbname = config$dbname, host = config$host,
  123. user = config$user, password = config$password,
  124. port = config$port
  125. ))
  126. } else {
  127. conn <- NULL
  128. print("Andmebaasiga \U00FChendamise parameetrid puudulikud. Palun kontrolli konfiguratsiooni faili.")
  129. return()
  130. }
  131. ## Andmebaasiga ühenduse kontroll
  132. if (exists("conn") && !inherits(conn, "try-error")) {
  133. print("Connection exist")
  134. } else {
  135. print("Connection error")
  136. }
  137. }
  138. db_connect()
  139. db_connect(conf = conf)
  140. config <- ruut::get_config()
  141. db_connect(conf = config)
  142. db_connect(conf = c("3"))
  143. conn
  144. dbDisconnect(conn)
  145. dbDisconnect(conn)
  146. conn
  147. library(ruut)
  148. db_connect()
  149. xxx <- db_connect()
  150. xxx
  151. library(ruut)
  152. xxx <- db_connect()
  153. db_connect()
  154. library(ruut)
  155. source(paste0(getwd(),"/R/db_connect.R"))
  156. conn <- db_connect()
  157. conn
  158. library(ruut)
  159. source(paste0(getwd(),"/R/db_connect.R"))
  160. conn <- db_connect()
  161. styler:::style_active_file()
  162. get_config <- function(conf = NULL) {
  163. if (is.null(conf)) {
  164. config <- rjson::fromJSON(file = system.file("extdata", "config.json", package = "ruut"))
  165. }
  166. else {
  167. config <- conf
  168. }
  169. return(config)
  170. }
  171. get_config
  172. get_config()
  173. styler:::style_active_file()
  174. styler:::style_active_file()
  175. styler:::style_active_file()
  176. library(ruut)
  177. library(ruut)
  178. qgis_algorithm_search_by_word(str = "bound")
  179. algorithm <- "native:boundingboxes"
  180. ## Read help!!!
  181. cat(qgis_show_help(algorithm = algorithm))
  182. # Run algorithm.
  183. library(ruut)
  184. library(ruut)
  185. source(paste0(getwd(),"/R/db_connect.R"))
  186. conn <- db_connect()
  187. all_schemas <- DBI::dbGetQuery(conn, "SELECT SCHEMA_NAME FROM INFORMATION_SCHEMA.SCHEMATA")
  188. all_schemas
  189. db_all_schemas <- function() {
  190. source(paste0(getwd(),"/R/db_connect.R"))
  191. conn <- db_connect()
  192. all_schemas <- DBI::dbGetQuery(conn, "SELECT SCHEMA_NAME FROM INFORMATION_SCHEMA.SCHEMATA")
  193. all_schemas$schema_name
  194. }
  195. db_all_schemas()
  196. db_is_shema_exist <- function(schema = NULL) {
  197. if(schema %in% db_all_schemas()) return(TRUE) else return(FALSE)
  198. }
  199. db_is_shema_exist("xxxx")
  200. aaa <- db_is_shema_exist("xxxx")
  201. aaa <- db_is_shema_exist("x_matsalu")
  202. aaa <- db_is_shema_exist("x_matsalu")
  203. schema = "x_matsalu"
  204. schema %in% db_all_schemas()
  205. db_all_schemas()
  206. aaa <- db_is_shema_exist(schema = "x_matsalu")
  207. aaa
  208. aaa <- db_is_shema_exist(schema = "sx_matsalu")
  209. aaa <- db_is_shema_exist(schema = "sx_matsalu")
  210. aaa <- db_is_shema_exist(schema = "sx_matsalu")
  211. db_is_shema_exist <- function(schema = NULL) {
  212. if(schema %in% db_all_schemas())
  213. return(TRUE)
  214. else
  215. return(FALSE)
  216. }
  217. aaa <- db_is_shema_exist(schema = "sx_matsalu")
  218. aaa <- db_is_shema_exist(schema = "sx_matsalu")
  219. aaa
  220. aaa <- db_is_shema_exist(schema = "x_matsalu")
  221. aaa <- db_is_shema_exist(schema = "x_matsalu")
  222. DBI::dbDisconnect(conn)
  223. DBI::dbDisconnect(conn)
  224. DBI::dbDisconnect(conn)
  225. aaa <- db_is_shema_exist(schema = "x_matsalu")
  226. aaa <- db_is_shema_exist(schema = "x_matsalu")
  227. aaa <- db_is_shema_exist(schema = "x_matsalu")
  228. aaa <- db_is_shema_exist(schema = "x_matsalu")
  229. db_is_shema_exist(schema = "x_matsalu")
  230. DBI::dbDisconnect(conn)
  231. DBI::dbDisconnect(conn)
  232. DBI::dbDisconnect(conn)
  233. DBI::dbDisconnect(conn)
  234. DBI::dbDisconnect(conn)
  235. DBI::dbDisconnect(conn)
  236. db_is_shema_exist(schema = "x_matsalu")
  237. conn <- db_connect()
  238. all_schemas <- DBI::dbGetQuery(conn, "SELECT SCHEMA_NAME FROM INFORMATION_SCHEMA.SCHEMATA")
  239. all_schemas$schema_name
  240. db_all_schemas <- function() {
  241. source(paste0(getwd(),"/R/db_connect.R"))
  242. conn <- db_connect()
  243. all_schemas <- DBI::dbGetQuery(conn, "SELECT SCHEMA_NAME FROM INFORMATION_SCHEMA.SCHEMATA")
  244. return (all_schemas$schema_name)
  245. }
  246. db_all_schemas()
  247. db_all_schemas()
  248. db_all_schemas()
  249. db_all_schemas()
  250. source(paste0(getwd(),"/R/db_connect.R"))
  251. conn <- db_connect()
  252. source(paste0(getwd(),"/R/db_connect.R"))
  253. conn <- db_connect()
  254. source(paste0(getwd(),"/R/db_connect.R"))
  255. conn <- db_connect()
  256. db_all_schemas <- function() {
  257. source(paste0(getwd(),"/R/db_connect.R"))
  258. conn <- db_connect()
  259. all_schemas <- DBI::dbGetQuery(conn, "SELECT SCHEMA_NAME FROM INFORMATION_SCHEMA.SCHEMATA")
  260. return (all_schemas$schema_name)
  261. }
  262. # db_all_schemas()
  263. db_is_shema_exist <- function(schema = NULL) {
  264. if(schema %in% db_all_schemas())
  265. return(TRUE)
  266. else
  267. return(FALSE)
  268. }
  269. DBI::dbDisconnect(conn)
  270. conn <- db_connect()
  271. conn <- db_connect()
  272. conn <- db_connect()
  273. library(ruut)
  274. conn <- db_connect()
  275. source(paste0(getwd(),"/R/db_connect.R"))
  276. conn <- db_connect()
  277. all_schemas <- DBI::dbGetQuery(conn, "SELECT SCHEMA_NAME FROM INFORMATION_SCHEMA.SCHEMATA")
  278. all_schemas
  279. all_schemas$schema_name
  280. library(ruut)
  281. db_all_schemas <- function() {
  282. source(paste0(getwd(),"/R/db_connect.R"))
  283. conn <- db_connect()
  284. all_schemas <- DBI::dbGetQuery(conn, "SELECT SCHEMA_NAME FROM INFORMATION_SCHEMA.SCHEMATA")
  285. return (all_schemas$schema_name)
  286. }
  287. # db_all_schemas()
  288. db_is_shema_exist <- function(schema = NULL) {
  289. if(schema %in% db_all_schemas())
  290. return(TRUE)
  291. else
  292. return(FALSE)
  293. }
  294. db_all_schemas()
  295. db_is_shema_exist <- function(schema = NULL) {
  296. if(schema %in% db_all_schemas())
  297. return(TRUE)
  298. else
  299. return(FALSE)
  300. }
  301. aaa <- db_is_shema_exist(schema = "x_matsalu")
  302. aaa <- db_is_shema_exist(schema = "x_matsalu")
  303. aaa <- db_is_shema_exist(schema = "xx_matsalu")
  304. schema = "xx_matsalu"
  305. schema %in% db_all_schemas()
  306. schema %in% db_all_schemas()
  307. if(schema %in% db_all_schemas())
  308. TRUE
  309. else
  310. FALSE
  311. if(schema %in% db_all_schemas())
  312. TRUE
  313. else
  314. FALSE
  315. if(schema %in% db_all_schemas())
  316. TRUE
  317. if(schema %in% db_all_schemas())
  318. TRUE
  319. library(ruut)
  320. db_all_schemas <- function() {
  321. source(paste0(getwd(),"/R/db_connect.R"))
  322. conn <- db_connect()
  323. all_schemas <- DBI::dbGetQuery(conn, "SELECT SCHEMA_NAME FROM INFORMATION_SCHEMA.SCHEMATA")
  324. return (all_schemas$schema_name)
  325. }
  326. db_all_schemas()
  327. db_is_shema_exist <- function(schema = NULL) {
  328. if(schema %in% db_all_schemas())
  329. TRUE
  330. else
  331. FALSE
  332. }
  333. db_is_shema_exist(schema = "xx_matsalu")
  334. db_is_shema_exist(schema = "x_matsalu")
  335. db_is_shema_exist(schema = "x_matsalu")
  336. db_create_new_schema <- function(conf) {
  337. conn <- db_connect()
  338. all_schemas <- DBI::dbGetQuery(conn,sprintf(
  339. "-- DROP SCHEMA x_matsalu;
  340. CREATE SCHEMA %s AUTHORIZATION %s;", conf$schema, conf$user))
  341. }
  342. db_create_new_schema(conf)
  343. styler:::style_active_file()
  344. db_create_new_schema <- function(conf) {
  345. conn <- db_connect()
  346. DBI::dbExecute(conn, sprintf(
  347. "-- DROP SCHEMA x_matsalu;
  348. CREATE SCHEMA %s AUTHORIZATION %s;", conf$schema, conf$user
  349. ))
  350. }
  351. conf <- ruut::get_config()
  352. conf
  353. db_create_new_schema <- function(conf) {
  354. conn <- db_connect()
  355. DBI::dbExecute(conn, sprintf(
  356. "-- DROP SCHEMA x_matsalu;
  357. CREATE SCHEMA %s AUTHORIZATION %s;", conf$schema, conf$user
  358. ))
  359. }
  360. db_create_new_schema(conf)
  361. conf$schema <- "x_valga"
  362. db_create_new_schema(conf)
  363. source(paste0(getwd(), "/R/db_all_schemas"))
  364. source(paste0(getwd(), "/R/db_all_schemas.R"))
  365. paste0(getwd(), "/R/db_all_schemas.R")
  366. source(paste0(getwd(), "/R/db_all_schemas.R"))
  367. db_is_shema_exist(schema = "x_matsalu")
  368. db_is_shema_exist(schema = "x_matsalu")
  369. db_is_shema_exist(schema = "zx_matsalu")
  370. styler:::style_active_file()
  371. styler:::style_active_file()
  372. db_create_new_schema <- function(conf) {
  373. source(paste0(getwd(), "/R/db_is_shema_exist.R"))
  374. if(db_is_shema_exist(schema)) {
  375. conn <- db_connect()
  376. DBI::dbExecute(conn, sprintf(
  377. "-- DROP SCHEMA x_matsalu;
  378. CREATE SCHEMA %s AUTHORIZATION %s;", conf$schema, conf$user
  379. ))
  380. }
  381. }
  382. conf <- ruut::get_config()
  383. conf$schema <- "x_valga"
  384. db_create_new_schema(conf)
  385. conf <- ruut::get_config()
  386. conf$schema <- "x_valga1"
  387. db_create_new_schema(conf)
  388. conf <- ruut::get_config()
  389. conf
  390. conf$schema <- "x_valga1"
  391. conf
  392. db_create_new_schema(conf)
  393. conf$schema
  394. db_create_new_schema <- function(conf) {
  395. source(paste0(getwd(), "/R/db_is_shema_exist.R"))
  396. if(!db_is_shema_exist(conf$schema)) {
  397. conn <- db_connect()
  398. DBI::dbExecute(conn, sprintf(
  399. "-- DROP SCHEMA x_matsalu;
  400. CREATE SCHEMA %s AUTHORIZATION %s;", conf$schema, conf$user
  401. ))
  402. }
  403. }
  404. conf <- ruut::get_config()
  405. conf$schema <- "x_valga1"
  406. db_create_new_schema(conf)
  407. conf <- ruut::get_config()
  408. conf$schema <- "x_valga1"
  409. db_create_new_schema(conf)
  410. library(ruut)
  411. conf <- ruut::get_config()
  412. conf
  413. conf$schema <- "x_valga1"
  414. db_create_new_schema(conf)
  415. db_create_new_schema <- function(conf) {
  416. source(paste0(getwd(), "/R/db_is_shema_exist.R"))
  417. if(!db_is_shema_exist(conf$schema)) {
  418. conn <- db_connect()
  419. DBI::dbExecute(conn, sprintf(
  420. "-- DROP SCHEMA x_matsalu;
  421. CREATE SCHEMA %s AUTHORIZATION %s;", conf$schema, conf$user
  422. ))
  423. }
  424. }
  425. db_create_new_schema(conf)
  426. DBI::dbDisconnect(conn)
  427. conf <- ruut::get_config()
  428. conf$schema <- "x_valga1"
  429. db_create_new_schema(conf)
  430. conf <- ruut::get_config()
  431. conf$schema <- "x_valga1"
  432. db_create_new_schema(conf)
  433. conf <- ruut::get_config()
  434. conf$schema <- "x_valga"
  435. db_create_new_schema(conf)
  436. conf <- ruut::get_config()
  437. conf$schema <- "x_valga"
  438. db_create_new_schema(conf)
  439. conf <- ruut::get_config()
  440. conf$schema <- "x_valga"
  441. db_create_new_schema(conf)
  442. conf <- ruut::get_config()
  443. conf$schema <- "x_valga"
  444. db_create_new_schema(conf)
  445. styler:::style_active_file()
  446. library(ruut)
  447. styler:::style_active_file()
  448. library(ruut)
  449. styler:::style_active_file()
  450. library(ruut)
  451. library(ruut)