我想提取所有Create Statements在我的 50 MySQL数据库通过 SHOW CREATE TABLE db.table或 SHOW CREATE TABLE db1.mytable或 SHOW CREATE TABLE db2.sometable或 SHOW CREATE TABLE db3.mytable1 .因此每个数据库在 db1(table,mytable...) db2(table1,sometable) and so on 中都有一些表

通过示例查询说明数据库:

SELECT *
FROM db.table1 m
   LEFT JOIN db1.sometable o ON m.id = o.id
   LEFT JOIN db2.sometables t ON p.id=t.id
   LEFT JOIN db3.sometable s ON s.column='john'


library(RMySQL)
library(DBI)

con <-  dbConnect(RMySQL::MySQL(), 
                    username = "", 
                    password = "",
                    host = "", 
                    port = 3306,
                    dbname= mydbname)#  when using dbs<-dbGetQuery(con ,"SHOW DATABASES") I have to ## dbname= mydbname## to get all DBs 

使用 dbs<-dbGetQuery(con ,"SHOW DATABASES")我可以将 dbConnection 中的所有 50 个数据库提取为字符向量。我想遍历 dbs 中的每个数据库并申请 SHOW CREATE TABLE到每一行/数据库。我想我必须将每一行/数据库解析为 dbname= mydbname和 dbs<-dbGetQuery(con ,"SHOW CREATE TABLE") .但我只是不知道如何制作循环

我试过:

apply(dbs, 1, function(row) {
      dbname <- row[]
      for (i in 1:length(dbname)) {

        create<-dbGetQuery(con,"SHOW CREATE TABLE") }

    })

但这似乎不对。我想我必须包括 con以某种方式进入循环。否则我会得到: Error in .local(drv, ...) : object 'dbname' not found

所以我尝试了:

apply(dbs, 1, function(row) {
      dbname <- row[]
      for (i in 1:length(dbname)) {
                    con <-  dbConnect(RMySQL::MySQL(), 
                    username = "", 
                    password = "",
                    host = "", 
                    port = 3306,
                    dbname= [i])
        create<-dbGetQuery(con,"SHOW CREATE TABLE") }})

我想这很接近解决方案，但我遗漏了一些东西:

dbs<-dbGetQuery(con,"show databases")

library(foreach)

foreach(i = 1:(length(dbs))%dopar%{
  query<-paste("SHOW CREATE TABLE",dbs[i])
  creates<-dbGetQuery(con,query)
})

最佳答案

考虑这种导入每个数据库的数据框(不包括系统数据库、INFORMATION_SCHEMA 和 MYSQL)及其对应表的方法。然后，运行 SHOW CREATE TABLE 语句。最后，将原始数据框与创建语句的绑定(bind)数据框合并。

现在，需要注意的是表在数据库中重复名称。要返回此类组合的不同值，使用 head 函数的 aggregate()。

con <-  dbConnect(RMySQL::MySQL(),
                  username = "****", password = "****",
                  host = "****", port = 3306,
                  dbname= "****")
dbtbls <- dbGetQuery(con, "SELECT `TABLE_SCHEMA` AS `Database`, 
                                  `TABLE_NAME` AS `Table`
                            FROM  `INFORMATION_SCHEMA`.`TABLES` 
                            WHERE `TABLE_TYPE` = 'BASE TABLE'
                              AND `TABLE_SCHEMA` NOT LIKE '%SCHEMA%' 
                              AND `TABLE_SCHEMA` NOT LIKE '%MYSQL%' ")
# LIST OF SQL STATEMENTS
sql <- paste0("SHOW CREATE TABLE ", dbtbls$Database, ".", dbtbls$Table)

# LIST OF DATAFRAMES
createstmts <- lapply(sql, function(x) dbGetQuery(con, x))
dbDisconnect(con)

# ROW BIND LIST INTO ONE DATAFRAME TO MERGE WITH ORIGINAL    
stmtsdf <- do.call(rbind, createstmts)
finaldf <- merge(dbtbls, stmtsdf, by='Table')

# RETURN DISTINCT RECORDS
finaldf <- aggregate(.~Database+Table, finaldf, FUN=head, 1)

关于mysql - 如何从 MySQL 数据库的不同表中提取创建语句？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/35456473/