本文介绍通过Phoenix SQL Java API访问Lindorm宽表引擎的具体操作和使用示例。

前提条件

  • 已安装Java环境,要求安装JDK 1.8及以上版本。
  • 已下载PhoenixSQL SDK,下载链接请参见Phoenix
  • 已获取Lindorm宽表引擎的链接地址,具体操作请参见查看连接地址
  • 已将访问数据库的IP地址加入至云原生多模数据库Lindorm白名单中。具体操作请参见设置白名单

操作步骤

  1. 创建连接。在Project中输入下述代码,填写Lindorm宽表引擎的链接地址和用户名密码。
    String url = "jdbc:phoenix:thin:url=http://ld-xxxxx-m1-ps-proxy-phoenix.hbaseue.rds.aliyuncs.com:8765;serialization=PROTOBUF";
    Properties props = new Properties();
    props.put("user", "root");
    props.put("password", "root");
    Connection pconn = DriverManager.getConnection(url, props);
    pconn.setAutoCommit(true);
  2. 通过PhoenixSQL访问Lindorm宽表引擎的示例代码。
    Statement stmt = null;
    try {  
        stmt = pconn.createStatement();  
        stmt.execute("create table test(c1 integer, c2 integer, constraint pk primary key(c1))");  
        stmt.execute("upsert into test(c1,c2) values(1,1)");  
        ResultSet rs = stmt.executeQuery("select * from test");  
        while (rs.next()) {    
            int c1 = rs.getInt("c1");    
            int c2 = rs.getInt("c2");    
            System.out.println("c1=" + c1 + ",c2=" + c2);  
        }
    } catch (Throwable e) {  
        e.printStackTrace();
    } finally {  
        if (stmt != null) {    
            stmt.close();  
        }
    }