我无法使用 scala 将记录插入预言机数据库

Question

我正在尝试使用 Scala 将记录插入 Oracle 数据库并收到错误

db1.scala：18：错误：值提交不是 java.sql.语句的成员 statement.commit（）

object ScalaJdbcConnectSelect {
         def main(args: Array[String]) {
                val driver = "oracle.jdbc.driver.OracleDriver"
                val url = "jdbc:oracle:thin:@cdtsdcpt-scan.rxcorp.com:1521/DDCPAD00.WORLD"
                val username = "DCA_DATA"
                val password = "DCA_DATA"
                var connection:Connection = null
            try {
                Class.forName(driver)
                connection = DriverManager.getConnection(url, username, password)
                // create the statement, and run the select query
                val statement = connection.createStatement()
//                      val resultSet = statement.executeQuery("SELECT org_short_nm FROM dc_org")
                val sql_st="INSERT INTO DCP_ITALY_STG" + " VALUES ('20411384','71771622','4378038','257.550','15.000')"
                statement.executeUpdate(sql_st)
                println("Inserted records into the table...")
                val resultSet = statement.executeQuery("SELECT num FROM DCP_ITALY_STG")
                connection.commit()
                println("Hello india")
                while ( resultSet.next() )
                {
                        val host = resultSet.getString("num")
                        println(host)
                        println("Hello india")
                }
            } catch {
              case e: Throwable => e.printStackTrace
            }
                connection.close()
        }
        }}
}

Answer 1

它应该是

connection.commit()

而不是

statement.commit()

文档 说：

Connection#commit() - 使自上次提交/回滚以来所做的所有更改永久化 并释放此连接当前持有的任何数据库锁 对象。