import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.Statement;
import java.sql.*;
public class JDBC_Test {
public static void main(String args[]) {
Connection c = null;
Statement stmt = null;
try {
Class.forName(“org.postgresql.Driver”);
c = DriverManager.getConnection(“jdbc:postgresql://xxx:5432/tpch”, “test”, “test123456”);
c.setAutoCommit(false); // 把自动提交
System.out.println(“Opened database successfully”);
stmt = c.createStatement();
String sql_drop = “DROP TABLE if exists STUDENTS01”;
stmt.execute(sql_drop);
System.out.println(“drop table successfully”);
String sql = “CREATE TABLE STUDENTS01 " +
“(ID INT NOT NULL ,” +
" NAME TEXT NOT NULL, " +
" SEX TEXT NOT NULL, " +
" AGE TEXT NOT NULL) with (appendonly=true,orientation=orc,compresstype=lz4,dicthreshold=0.8)”;
stmt.execute(sql);
System.out.println(“Table created successfully”);
String sql_insert = “insert into students01 select 1,‘a’,‘b’,‘c’”;
String sql_insert01 = “insert into students01 select 2,‘a’,‘b’,‘c’”;
stmt.execute(sql_insert);
stmt.execute(sql_insert01);
System.out.println(“data insert successfully”);
String sql_select = “select * from students01”;
PreparedStatement ps = c.prepareStatement(sql_select);
//5.查询数据库
ResultSet rs = ps.executeQuery();
//6.操作结果集
while(rs.next()){ //这里逐行打印
System.out.println(rs.getObject(“id”)
+ “\t” + rs.getObject(“name”)
+ “\t” + rs.getObject(“age”));
}
System.out.println(“data select successfully”);
String sql_update = “update students01 set name = ‘b’ where id =1”;
stmt.execute(sql_update);
System.out.println(“update table successfully”);
String sql_delete = “delete from STUDENTS01 where id =2”;
stmt.execute(sql_drop);
System.out.println(“delete table successfully”);
stmt.close();
c.commit();
c.close();
} catch (Exception e) {
System.err.println(e.getClass().getName() + ": " + e.getMessage());
System.exit(0);
}
}
}