java 连接postgresql测试

2022-05-15 17:23:19

Java代码  java 连接postgresql测试
  1. package temp;  
  2.   
  3. /** 
  4.  * 
  5.  * @author JadeLuo 
  6.  */  
  7. import java.sql.Connection;  
  8. import java.sql.PreparedStatement;  
  9. import java.sql.ResultSet;  
  10. import java.sql.ResultSetMetaData;  
  11. import java.sql.SQLException;  
  12. import java.sql.Statement;  
  13.   
  14. import org.postgresql.ds.PGSimpleDataSource;  
  15.   
  16. public class PostgreSQLDataSource {  
  17.   
  18.     /** 
  19.       CREATE TABLE lfchat.auto_id_test ( id SERIAL primary key , username 
  20.       character(8) NOT NULL, password character(6) NOT NULL, email character(6) NOT NULL ) WITH ( OIDS=FALSE ); 
  21.       ALTER TABLE lfchat.auto_id_test OWNER TO sdbadmin; 
  22.      * 
  23.      * @param args 
  24.      * @throws SQLException 
  25.      */  
  26.     public static void main(String[] args) throws SQLException {  
  27.         PGSimpleDataSource pgSimpleDataSource = new PGSimpleDataSource();  
  28.         pgSimpleDataSource.setServerName("ip:11780");  
  29. //        pgSimpleDataSource.setServerName("192.168.1.8");//default 5432  
  30. //        pgSimpleDataSource.setDatabaseName("postgres");  
  31. //        pgSimpleDataSource.setDatabaseName("foo");  
  32.         pgSimpleDataSource.setDatabaseName("foo");  
  33. //        pgSimpleDataSource.setUser("lv");  
  34. //        pgSimpleDataSource.setPassword("lv");  
  35.         pgSimpleDataSource.setUser("sdbadmin");  
  36.         pgSimpleDataSource.setPassword("sa");  
  37.         Connection conn = pgSimpleDataSource.getConnection();  
  38.         Statement state = conn.createStatement();  
  39.   
  40.         String sql = "insert into lfchat.auto_id_test (username,password,email) values (?,?,?);";  
  41.         PreparedStatement pstmt = (PreparedStatement) conn.prepareStatement(sql, Statement.RETURN_GENERATED_KEYS);//传入参数：Statement.RETURN_GENERATED_KEYS  
  42.         pstmt.setString(1, "username");  
  43.         pstmt.setString(2, "pwd");  
  44.         pstmt.setString(3, "email");  
  45.         pstmt.executeUpdate();//执行sql                                                                             int autoInckey = -1;  
  46.         ResultSet rs = pstmt.getGeneratedKeys(); //获取结果     
  47.         if (rs.next()) {  
  48.             int autoIncKey = rs.getInt(1);//取得ID  
  49.             System.out.println("autoIncKey=>>>>>>>>>>" + autoIncKey);  
  50.         } else {  
  51.             // throw an exception from here  
  52.         }  
  53.    
  54.     }  
  55.   
  56.     static void showResultSet(ResultSet resultSet) throws SQLException {  
  57.         ResultSetMetaData resultSetMetaData = resultSet.getMetaData();  
  58.         int num = resultSetMetaData.getColumnCount();  
  59.         while (resultSet.next()) {  
  60.             for (int i = 1; i <= num; i++) {  
  61.                 System.out.print(resultSetMetaData.getCatalogName(i) + " "  
  62.                         + resultSet.getString(i));  
  63.             }  
  64.             System.out.println();  
  65.         }  
  66.     }  
  67. }  
上一篇：linux下卸载自带mysql


下一篇：阿里云服务器企业站如何选择适合自己的云服务器配置？