使用groovy sql迁移数据库表时遇到问题

Question

我想使用不同的sql连接从一个表中选择数据并批量插入到另一个表中。两张表的设置完全相同。目前我有：

destination.withBatch(1000) { stmt ->

    source.eachRow(selectQuery) {

        String insertString = """
                    INSERT INTO dest_table
                    VALUES (
                          ${it[0]},
                          ${it[1]});
                    """

        try {
            stmt.addBatch(insertString)
        }
        catch (Exception e) {
            println insertString
        }
    }
}

在此过程中的数据类型似乎发生了一些事情，因为由于冒号而插入像 'a:string' 这样的字符串非常不高兴。

我可以执行 '${it[0]}' 来强制将其视为字符串，但是当我使用其他数据类型时，这会导致问题。

此外，我的错误处理肯定无法正常工作。我希望它打印出它无法执行的插入，然后优雅地继续。

谢谢

Answer 1

groovy sql 很可能正在从您的 sql 字符串创建一个准备好的语句，并且其中带有冒号的任何内容都会被解析为参数占位符。

因此，我建议顺应流程，单独绑定数据值，而不是将它们内联到 sql 语句中。这也可能会提高性能，因为准备好的语句可以由数据库缓存。