我使用的是phoenix-4.7.0-hbase-1.1-bin。我正在尝试使用 PreparedStatement
api,但不会插入任何行,也不会引发异常。以下是我的示例程序:
import java.sql.*;
public class PhoenixExample {
public static void main(String[] args) {
try {
// create a mysql database connection
String myDriver = "org.apache.phoenix.jdbc.PhoenixDriver";
String myUrl = "jdbc:phoenix:host:2181:/hbase";
Class.forName(myDriver);
Connection conn = DriverManager.getConnection(myUrl, "", "");
String query = "UPSERT INTO floattest(value1, value2) values(?, ?)";
// create the mysql insert preparedstatement
PreparedStatement preparedStmt = conn.prepareStatement(query);
preparedStmt.setFloat(1, 1094993918);
preparedStmt.setFloat(2,804081421);
// execute the preparedstatement
boolean executed = preparedStmt.execute();
System.out.println("EXECUTED = " + executed);
preparedStmt.close();
conn.close();
} catch (Exception e) {
e.printStackTrace();
System.err.println("Got an exception!" + e);
System.err.println(e.getMessage());
}
}
}
我在准备发言时有没有遗漏什么?我应该如何修改它以成功插入一行?
2条答案
按热度按时间mefy6pfw1#
必须在执行准备好的语句后调用commit。通常自动提交设置为10000行。尝试执行commit preparedstatement
8aqjt8rx2#
得到同样的结果。
实际上,表中有一些数据,只有主键。
select * from
会给空的,但是select pk from
只会给pk。这是非常荒谬的,因为它也检查
some column is set to varchar(10) but insert a string length=12
,但只插入主键。