Java连接PostgreSQL数据库，增删改查

冷不防 2023-01-01 08:58 396阅读 0赞

[https://blog.csdn.net/u013456370/article/details/79668420][https_blog.csdn.net_u013456370_article_details_79668420]

通过eclipse工具，新建Maven项目：

添加：postgresql的jar包（我使用的是：版本：42.2.2）

修改pom.xml文件：

1.  ``
2.  `<dependency>`
3.  `<groupId>org.postgresql</groupId>`
4.  `<artifactId>postgresql</artifactId>`
5.  `<version>42.2.2</version>`
6.  `</dependency>`

**一、Java通过JDBC连接到PostgreSQL数据库**

1.  `package com.accord;`
2.   
3.  `import java.sql.Connection;`
4.  `import java.sql.DriverManager;`
5.   
6.  `public class PostgreSqlJdbcConn {`
7.  `@SuppressWarnings("unused")`
8.  `public static void main(String args[]) {`
9.  `Connection c = null;`
10. `try {`
11. `Class.forName("org.postgresql.Driver");`
12. `c = DriverManager`
13. `.getConnection("jdbc:postgresql://localhost:5432/db_person",`
14. `"postgres", "123456");`
15. `} catch (Exception e) {`
16. `e.printStackTrace();`
17. `System.err.println(e.getClass().getName()+": "+e.getMessage());`
18. `System.exit(0);`
19. `}`
20. `System.out.println("Opened database successfully");`
21. `}`
22. `}`

运行结果：Opened database successfully

**二、创建表**

运行结果：

连接数据库成功！

新表创建成功！

**三、插入数据**

1.  `package com.accord;`
2.   
3.  `import java.sql.Connection;`
4.  `import java.sql.DriverManager;`
5.  `import java.sql.Statement;`
6.   
7.  `public class PostgreSqlJdbcConnAddDatas {`
8.  `public static void main(String args[]) {`
9.  `Connection c = null;`
10. `Statement stmt = null;`
11. `try {`
12. `Class.forName("org.postgresql.Driver");`
13. `c = DriverManager.getConnection(`
14. `"jdbc:postgresql://localhost:5432/db_person", "postgres",`
15. `"123456");`
16. `c.setAutoCommit(false);`
17.  
18. `System.out.println("连接数据库成功！");`
19. `stmt = c.createStatement();`
20.  
21. `String sql = "INSERT INTO COMPANY02 (ID,NAME,AGE,ADDRESS,SALARY) "`
22. `+ "VALUES (1, 'Paul', 32, 'California', 20000.00 );";`
23. `stmt.executeUpdate(sql);`
24.  
25. `sql = "INSERT INTO COMPANY02 (ID,NAME,AGE,ADDRESS,SALARY) "`
26. `+ "VALUES (2, 'Allen', 25, 'Texas', 15000.00 );";`
27. `stmt.executeUpdate(sql);`
28.  
29. `sql = "INSERT INTO COMPANY02 (ID,NAME,AGE,ADDRESS,SALARY) "`
30. `+ "VALUES (3, 'Teddy', 23, 'Norway', 20000.00 );";`
31. `stmt.executeUpdate(sql);`
32.  
33. `sql = "INSERT INTO COMPANY02 (ID,NAME,AGE,ADDRESS,SALARY) "`
34. `+ "VALUES (4, 'Mark', 25, 'Rich-Mond ', 65000.00 );";`
35. `stmt.executeUpdate(sql);`
36.  
37. `stmt.close();`
38. `c.commit();`
39. `c.close();`
40.  
41. `} catch (Exception e) {`
42. `e.printStackTrace();`
43. `System.err.println(e.getClass().getName() + ": " + e.getMessage());`
44. `System.exit(0);`
45. `}`
46. `System.out.println("新增数据成功！");`
47. `}`
48. `}`

运行结果：

连接数据库成功！

新增数据成功！

**四、查询数据**

1.  `package com.accord;`
2.   
3.  `import java.sql.Connection;`
4.  `import java.sql.DriverManager;`
5.  `import java.sql.ResultSet;`
6.  `import java.sql.Statement;`
7.   
8.  `import javax.naming.spi.DirStateFactory.Result;`
9.   
10. `public class PostgreSqlJdbcConnSelectDatas {`
11. `public static void main(String args[]) {`
12. `Connection c = null;`
13. `Statement stmt = null;`
14. `try {`
15. `Class.forName("org.postgresql.Driver");`
16. `c = DriverManager.getConnection(`
17. `"jdbc:postgresql://localhost:5432/db_person", "postgres",`
18. `"123456");`
19. `c.setAutoCommit(false);`
20.  
21. `System.out.println("连接数据库成功！");`
22. `stmt = c.createStatement();`
23.  
24. `ResultSet rs = stmt.executeQuery("select * from company02");`
25. `while(rs.next()){`
26. `int id = rs.getInt("id");`
27. `String name = rs.getString("name");`
28. `int age = rs.getInt("age");`
29. `String address = rs.getString("address");`
30. `float salary = rs.getFloat("salary");`
31. `System.out.println(id + "," + name + "," + age + "," + address.trim() + "," + salary);`
32. `}`
33.  
34. `rs.close();`
35. `stmt.close();`
36.  
37. `c.close();`
38.  
39. `} catch (Exception e) {`
40. `e.printStackTrace();`
41. `System.err.println(e.getClass().getName() + ": " + e.getMessage());`
42. `System.exit(0);`
43. `}`
44. `System.out.println("查询数据成功！");`
45. `}`
46. `}`

运行结果：

连接数据库成功！

查询数据成功！

**五、更新数据**

1.  `package com.accord;`
2.   
3.  `import java.sql.Connection;`
4.  `import java.sql.DriverManager;`
5.  `import java.sql.ResultSet;`
6.  `import java.sql.Statement;`
7.   
8.  `import javax.naming.spi.DirStateFactory.Result;`
9.   
10. `public class PostgreSqlJdbcConnUpdateData {`
11. `public static void main(String args[]) {`
12. `Connection c = null;`
13. `Statement stmt = null;`
14. `try {`
15. `Class.forName("org.postgresql.Driver");`
16. `c = DriverManager.getConnection(`
17. `"jdbc:postgresql://localhost:5432/db_person", "postgres",`
18. `"123456");`
19. `c.setAutoCommit(false);`
20.  
21. `System.out.println("连接数据库成功！");`
22. `stmt = c.createStatement();`
23.  
24. `String sql = "Delete from COMPANY02 where ID=4 ";`
25. `stmt.executeUpdate(sql);`
26. `c.commit();`
27.  
28. `ResultSet rs = stmt.executeQuery("select * from company02 order by id");`
29. `while(rs.next()){`
30. `int id = rs.getInt("id");`
31. `String name = rs.getString("name");`
32. `int age = rs.getInt("age");`
33. `String address = rs.getString("address");`
34. `float salary = rs.getFloat("salary");`
35. `System.out.println(id + "," + name + "," + age + "," + address.trim() + "," + salary);`
36. `}`
37.  
38. `rs.close();`
39. `stmt.close();`
40.  
41. `c.close();`
42.  
43. `} catch (Exception e) {`
44. `e.printStackTrace();`
45. `System.err.println(e.getClass().getName() + ": " + e.getMessage());`
46. `System.exit(0);`
47. `}`
48. `System.out.println("更新数据成功！");`
49. `}`
50. `}`

运行结果：

连接数据库成功！

更新数据成功！

**六、删除数据**

1.  `package com.accord;`
2.   
3.  `import java.sql.Connection;`
4.  `import java.sql.DriverManager;`
5.  `import java.sql.ResultSet;`
6.  `import java.sql.Statement;`
7.   
8.  `import javax.naming.spi.DirStateFactory.Result;`
9.   
10. `public class PostgreSqlJdbcConnDeleteData {`
11. `public static void main(String args[]) {`
12. `Connection c = null;`
13. `Statement stmt = null;`
14. `try {`
15. `Class.forName("org.postgresql.Driver");`
16. `c = DriverManager.getConnection(`
17. `"jdbc:postgresql://localhost:5432/db_person", "postgres",`
18. `"123456");`
19. `c.setAutoCommit(false);`
20.  
21. `System.out.println("连接数据库成功！");`
22. `stmt = c.createStatement();`
23.  
24. `String sql = "UPDATE COMPANY02 set SALARY = 250 where ID=1 ";`
25. `stmt.executeUpdate(sql);`
26. `c.commit();`
27.  
28. `ResultSet rs = stmt.executeQuery("select * from company02 order by id");`
29. `while(rs.next()){`
30. `int id = rs.getInt("id");`
31. `String name = rs.getString("name");`
32. `int age = rs.getInt("age");`
33. `String address = rs.getString("address");`
34. `float salary = rs.getFloat("salary");`
35. `System.out.println(id + "," + name + "," + age + "," + address.trim() + "," + salary);`
36. `}`
37.  
38. `rs.close();`
39. `stmt.close();`
40.  
41. `c.close();`
42.  
43. `} catch (Exception e) {`
44. `e.printStackTrace();`
45. `System.err.println(e.getClass().getName() + ": " + e.getMessage());`
46. `System.exit(0);`
47. `}`
48. `System.out.println("删除数据成功！");`
49. `}`
50. `}`

运行结果：

连接数据库成功！

1,Paul,32,California,250.0  
2,Allen,25,Texas,15000.0  
3,Teddy,23,Norway,20000.0

删除数据成功！

[https_blog.csdn.net_u013456370_article_details_79668420]: https://blog.csdn.net/u013456370/article/details/79668420