我试图使用Spring JDBCtemplate执行SQL:
INSERT INTO japan_wht.PIVOT_20427002(doc_header_text, value_date, total_amt, is_refund)
(SELECT
doc_header_text, DATE(value_date), SUM(LOCAL_CCY_AMT), is_refund
FROM
(SELECT
*
FROM
japan_wht.DATA_20427002
WHERE IS_REFUND in ('N')
) t
GROUP BY DATE(value_date) , doc_header_text, is_refund)
但是,它不会将任何内容插入数据库表,也不会丢弃错误。
当我尝试使用jdbctemplate执行SQL时,它可以在DB表中使用并插入数据:
INSERT INTO japan_wht.PIVOT_20427002(id, doc_header_text, value_date, total_amt, is_refund) values('1', '1', '2017-12-31', 3000, 'Y');
以下是我在SQL上方执行的呼吁:
jdbcTemplate.update(sqlString);
不确定这里怎么了。
我必须求助于普通的JDBC,并且有效:
Class.forName("com.mysql.jdbc.Driver");
Connection conn = DriverManager.getConnection("jdbc:mysql://localhost/mySchema?autoReconnect=true&useSSL=false&rewriteBatchedStatements=true",
"root", "root");
Statement stmt = conn.createStatement();
int flag = stmt.executeUpdate(sqlString);
LOGGER.info("Flag = {}", flag);
不确定为什么Spring JDBCtemplate无法处理此类东西!
您可以使用execute
方法。喜欢:
jdbcTemplate.execute("INSERT INTO table1 (some_id, some_key, some_text) " +
"SELECT id, key, text from table2 t2 " +
"LIMIT ?", (PreparedStatementCallback<Boolean>) ps -> {
ps.setInt(1, 400);
return ps.execute();
});