无法使用preparedstatement在phoenix中插入行

nr9pn0ug  于 2021-06-08  发布在  Hbase
关注(0)|答案(2)|浏览(401)

我使用的是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());
    }
  }
}

我在准备发言时有没有遗漏什么?我应该如何修改它以成功插入一行?

mefy6pfw

mefy6pfw1#

必须在执行准备好的语句后调用commit。通常自动提交设置为10000行。尝试执行commit preparedstatement

ps.executeUpdate();

conn.commit();
8aqjt8rx

8aqjt8rx2#

得到同样的结果。
实际上,表中有一些数据,只有主键。 select * from 会给空的,但是 select pk from 只会给pk。
这是非常荒谬的,因为它也检查 some column is set to varchar(10) but insert a string length=12 ,但只插入主键。

相关问题