将数据从R存储到DB2不起作用

问题描述：

我有一个DB2和R连接的奇怪问题。我可以访问数据库，但可以查询数据但我无法从R存储数据。我使用R的RODBC包。我遵循这里编写的指南https://www.ibm.com/developerworks/data/library/techarticle/dm-1402db2andr/index.html从技术上讲，此包从R对象创建“INSERT INTO”语句，并且在DB2上执行它以存储来自R的数据（我有必要的凭据在数据库上执行这些操作。）将数据从R存储到DB2不起作用

我试过的是以下内容（我使用R和SQuirreL - http://squirrel-sql.sourceforge.net/ - 一起测试多个单向）：

使用SQuirreL创建一个包含3列和25条记录的测试表。然后我从R查询这个表。我尝试将结果数据集中的第一条记录（从2）保存到同一个表中。然后我从R中查询表 - 附加行。然后我从SQuirreL查询。这里的问题发生在这里，而我连接到R和INSERT后。在（4）我看到添加的记录，但我无法从SQuirreL（5）中查询它。 R似乎锁定了整个桌子。当我用R与数据库断开连接时，它不会得到解决，我还会得到2条错误消息（我怀疑这些错误消息是相关的）。当我退出R然后它解决了，我可以从SQuirreL查询我的表，但附加的记录消失。

我试图从R发送的SQuirreL运行相同的SQL语句。我没有收到错误消息，并且记录被追加。因此R使用的方法应该可以工作。我不知道它在哪里横着。

我附上了我的表和使用的R脚本（包括运行时间消息）的示例数据。以下是CREATE TABLE语句。该表还没有任何索引或键，因此不会禁止添加重复记录。

 create table dm_quant.test (
     r_date   date, 
     cid    varchar(255), 
     priv_person  varchar(255) 
    );

有没有人遇到同样的困难？如果是这样，我该如何解决它？

提前致谢！

#connect-to-db2 
    rm(list=ls(all=TRUE)) 
    gc(reset = TRUE) 

    require(RODBC) 

    dsn_name <- "DB2_DB" 
    user <- "user" 
    pwd <- "pass" 


    channel <- odbcConnect(dsn = dsn_name, uid = user, pwd) 

    table_list <- sqlTables(channel, tableType = "TABLE", schema = "DM_QUANT") 
    cat("There are", nrow(table_list), "tables in the DM_QUANT schema.\n") 
    # There are 4 tables in the DM_QUANT schema. 

    table_name <- "DM_QUANT.TEST" 
    col_list <- sqlColumns(channel, table_name) 
    cat("There are", nrow(col_list), "columns defined in", table_name,"\n") 
    # There are 3 columns defined in DM_QUANT.TEST 

    ## Fetch test table (25 records) 
    test_tbl <- sqlQuery(channel, paste("SELECT * FROM ", table_name, sep = ""), 
         as.is = TRUE, na.strings = "") 

    ## Determine varTypes parameter for sqlSave 
    db2_var_types <- data.frame(var = col_list$COLUMN_NAME, 
           var_type = col_list$TYPE_NAME, 
           var_type_ext = paste(col_list$TYPE_NAME, "(", col_list$COLUMN_SIZE, ")", sep = ""), 
           stringsAsFactors = F) 

    db2_var_types$final_var_type <- db2_var_types$var_type 

    ## Adding size for VARCHAR variable type. 
    db2_var_types$final_var_type[db2_var_types$var_type == "VARCHAR"] <- db2_var_types$var_type_ext[db2_var_types$var_type == "VARCHAR"] 


    ## Append - append 1st record of the current table again. 
    sqlSave(channel, test_tbl[1,], tablename = table_name, append = T, verbose = T, 
      fast = F, rownames = F, colnames = F, varTypes = db2_var_types$final_var_type) 
    # Query: INSERT INTO DM_QUANT.TEST ("R_DATE", "CID", "PRIV_PERSON") VALUES ('2016-06-30', '193303', 'N') 

    ## After I use sqlSave I cannot query from the database from SQuirreL SQL Client. 
    ## Seems like I'm locking the whole table by R. 

    ## Test append 
    ## customer_test <- sqlFetch(channel, table_name) 
    test_append <- sqlQuery(channel, paste("SELECT * FROM ", table_name, sep = ""), 
           as.is = TRUE, na.strings = "") 

    nrow(test_append) 
    # [1] 26 
    nrow(test_append) == nrow(test_tbl) + 1 
    # [1] TRUE 

    ## Append seems successfull 
    cat("Record appended successfully.\n") 


    ## Close connections 
    odbcCloseAll() 
    cat("Database connections are closed.\n") 

    ## Always closes with 2 error message 
    # 1: [RODBC] Error in SQLDisconnect 
    # 2: [RODBC] Error in SQLFreeconnect 

    ## I still cannot query from SQuirreL SQL Client untill I close R completely 
    ## After I close and test query from SQuirreL, I cannot see the appended record.

我用于测试的Excel文件。

 **sample-data** 
    R_DATE  CID PRIV_PERSON 
    2016.06.30 193303 N 
    2016.06.30 808739 N 
    2016.06.30 585008 N 
    2016.06.30 479872 N 
    2016.06.30 350290 N 
    2016.06.30 895961 N 
    2016.06.30 822839 N 
    2016.06.30 746603 N 
    2016.06.30 174107 N 
    2016.06.30 858942 N 
    2016.06.30 710500 N 
    2016.06.30 513533 N 
    2016.06.30 303993 N 
    2016.06.30 14983 N 
    2016.06.30 91401 N 
    2016.06.30 364451 N 
    2016.06.30 147311 N 
    2016.06.30 165897 N 
    2016.06.30 988524 N 
    2016.06.30 445691 N 
    2016.06.30 119082 N 
    2016.06.30 4668 N 
    2016.06.30 8910 N 
    2017.12.31 377879 
    2016.06.30 531661 N

答

禁用自动提交会解释此行为。更新或插入的行保持锁定状态，直到它们被提交。当您强制关闭连接时，更改可能会回滚。

建立连接后立即尝试odbcSetAutoCommit(channel, autoCommit = TRUE)。或者，您可以在sqlSave()后发出odbcEndTran(channel, commit = TRUE)。

谢谢你的帮助，它解决了这个问题。 – ParraghG

将数据从R存储到DB2不起作用

相关推荐