代码实例

package oa.epoint.com.phoenix;import java.sql.Connection;import java.sql.DriverManager;import java.sql.ResultSet;import java.sql.SQLException;import java.sql.Statement;public class PhoenixTest {      private static String driver = "org.apache.phoenix.jdbc.PhoenixDriver";        public static void main(String[] args) throws SQLException {            try {                Class.forName(driver);                System.out.println("驱动加载成功");            } catch (ClassNotFoundException e) {                e.printStackTrace();            }            Statement stmt = null;            ResultSet rs = null;            System.out.println("准备数据库连接");            Connection con = DriverManager.getConnection("jdbc:phoenix:100.2.5.1:2181:/h -unsecure");            System.out.println("连接成功");            stmt = con.createStatement();            stmt.executeUpdate("drop table if  exists  test5");            stmt.executeUpdate("create table if not exists test5 (id BIGINT not null primary key,name varchar)");            stmt.executeUpdate("UPSERT INTO test5 VALUES(123,'xubin')");            con.commit();            String sql = "select * from test5";            rs = stmt.executeQuery(sql);            while (rs.next()) {                System.out.print("id:"+rs.getInt("id"));                System.out.println(",name:"+rs.getString("name"));            }            stmt.close();            con.close();        }}