安装

在我们开始之前，我们需要在Java程序中使用Postgresql，确保Postgresql的JDBC和Java已经在机器上安装。可以检查机器上是否安装了Java。现在，让我们检查如何设置JDBC驱动。

如果有关于Java JDBC概念了解不是很多，那么建议花半小时学习JDBC教程。

连接到数据库

下面的Java代码显示了如何连接到一个现有的数据库。如果数据库不存在，那么它就会被创建，终于将返回一个数据库对象。

1. importjava.sql.Connection;
2. importjava.sql.DriverManager;
4. publicclassPostgresqlJDBC{
5. publicstaticvoidmain(Stringargs[]){
6. Connectionc=null;
7. try{
8. Class.forName("org.postgresql.Driver");
9. c=DriverManager
10. .getConnection("jdbc:postgresql://localhost:5432/testdb",
11. "postgres","123");
12. }catch(Exceptione){
13. e.printStackTrace();
14. System.err.println(e.getClass().getName()+":"+e.getMessage());
15. System.exit(0);
16. }
17. System.out.println("Openeddatabasesuccessfully");
18. }
19. }

在编译和运行上面的程序，找到pg_hba.conf文件在Postgresql安装目录中，并添加下面一行：

1. #IPv4localconnections:
2. hostallall127.0.0.1/32md5

可以start/restartPostgres的服务器的情况下，它没有运行使用下面的命令：

1. [root@host]#servicepostgresqlrestart
2. Stoppingpostgresqlservice:[OK]
3. Startingpostgresqlservice:[OK]

现在让我们来编译和运行上面的程序，以获得testdb连接。在这里，我们使用的是 postgresas的用户ID和密码123来访问数据库。可以更改此数据库配置和设置。我们也假设当前版本的JDBC驱动程序为postgresql- 9.2-1002.jdbc3.jar，可在当前路径访问。

1. C:\JavaPostgresIntegration>javacPostgresqlJDBC.java
2. C:\JavaPostgresIntegration>java-cpc:\tools\postgresql-9.2-1002.jdbc3.jar;C:\JavaPostgresIntegrationPostgresqlJDBC
3. Opendatabasesuccessfully

创建表

下面的Java程序将被用于先前打开的数据库中创建一个表。确保这个表在目标数据库中没有创建过。

1. importjava.sql.*;
3. importjava.sql.Connection;
4. importjava.sql.DriverManager;
5. importjava.sql.Statement;
8. publicclassPostgresqlJDBC{
9. publicstaticvoidmain(Stringargs[])
10. {
11. Connectionc=null;
12. Statementstmt=null;
13. try{
14. Class.forName("org.postgresql.Driver");
15. c=DriverManager
16. .getConnection("jdbc:postgresql://localhost:5432/testdb",
17. "manisha","123");
18. System.out.println("Openeddatabasesuccessfully");
20. stmt=c.createStatement();
21. Stringsql="CREATETABLECOMPANY"+
22. "(IDINTPRIMARYKEYNOTNULL,"+
23. "NAMETEXTNOTNULL,"+
24. "AGEINTNOTNULL,"+
25. "ADDRESSCHAR(50),"+
26. "SALARYREAL)";
27. stmt.executeUpdate(sql);
28. stmt.close();
29. c.close();
30. }catch(Exceptione){
31. System.err.println(e.getClass().getName()+":"+e.getMessage());
32. System.exit(0);
33. }
34. System.out.println("Tablecreatedsuccessfully");
35. }
36. }

编译和执行程序时，它会创建公司表testdb的数据库中，并会显示以下两行：

1. Openeddatabasesuccessfully
2. Tablecreatedsuccessfully

INSERT 操作

下面的Java程序，显示我们如何在上面的例子中创建COMPANY表中的记录：

1. importjava.sql.Connection;
2. importjava.sql.DriverManager;
3. importjava.sql.Statement;
5. publicclassPostgresqlJDBC{
6. publicstaticvoidmain(Stringargs[]){
7. Connectionc=null;
8. Statementstmt=null;
9. try{
10. Class.forName("org.postgresql.Driver");
11. c=DriverManager
12. .getConnection("jdbc:postgresql://localhost:5432/testdb","123");
13. c.setAutoCommit(false);
14. System.out.println("Openeddatabasesuccessfully");
16. stmt=c.createStatement();
17. Stringsql="INSERTINTOCOMPANY(ID,NAME,AGE,ADDRESS,SALARY)"
18. +"VALUES(1,'Paul',32,'California',20000.00);";
19. stmt.executeUpdate(sql);
21. sql="INSERTINTOCOMPANY(ID,SALARY)"
22. +"VALUES(2,'Allen',25,'Texas',15000.00);";
23. stmt.executeUpdate(sql);
25. sql="INSERTINTOCOMPANY(ID,SALARY)"
26. +"VALUES(3,'Teddy',23,'Norway',SALARY)"
27. +"VALUES(4,'Mark','Rich-Mond',65000.00);";
28. stmt.executeUpdate(sql);
30. stmt.close();
31. c.commit();
32. c.close();
33. }catch(Exceptione){
34. System.err.println(e.getClass().getName()+":"+e.getMessage());
35. System.exit(0);
36. }
37. System.out.println("Recordscreatedsuccessfully");
38. }
39. }

当程序编译和执行，它会创建COMPANY表中的记录，并显示以下两行：

1. Openeddatabasesuccessfully
2. Recordscreatedsuccessfully

连接测试...