postgresql java的一些例子

postgresql ：http://www.postgresql.org/

pgadmin3：http://www.pgadmin.org/     //postgresql的可视化管理软件，类似于mysql的sqlyog

postgresql jdbc ：http://jdbc.postgresql.org/

postgresql jdbc interface ：http://jdbc.postgresql.org/documentation/head/index.html

一个小例子：

第一步：获得已有数据库的一个连接

1. load driver

2.getConnection

注册完Driver后，就可以使用DriverManager的方法了，这个可以具体参见jdk中的解释

Class.forName( "org.postgresql.Driver" ).newInstance();
                 
String url = "jdbc:postgresql://localhost:5432/kddcup2012" ;
                 
conn= DriverManager.getConnection(url, user , password );

url可以有三种形式：

jdbc:postgresql:database
jdbc:postgresql://host/database
jdbc:postgresql://host:port/database

而得到一个连接也有很多方法，最简单的就是像上面代码中的方法：

Connection db = DriverManager.getConnection(url, username, password);

例如，可以直接把username和password写到url中：

String ur= "jdbc:postgresql://localhost/test？user=fred&password=secret&ssl=true";
Connection conn = DriverManager.getConnection(url);

还可以设置Properties对象

String url = "jdbc:postgresql://localhost/test";
Properties props = new Properties();
props.setProperty("user","fred");
props.setProperty("password","secret");
props.setProperty("ssl","true");
Connection conn = DriverManager.getConnection(url, props);

以上两个方法都得到了一个ssh连接。

第二步，进行数据库操作

当获得数据库连接后就可以进行数据操作了，下面的部分会多一些简单的小例子，大多来自jdbc interface：

1.简单的查询语句1，使用statement

Statement st = conn.createStatement();
ResultSet rs = st.executeQuery("SELECT * FROM mytable WHERE columnfoo = 500");
while (rs.next()) {
    System.out.print("Column 1 returned ");
    System.out.println(rs.getString(1));
}
rs.close();
st.close();

还可以使用prepareStatement，对sql语句进行变量的填充

int foovalue = 500;
PreparedStatement st = conn.prepareStatement("SELECT * FROM mytable WHERE columnfoo = ?");
st.setInt(1, foovalue);
ResultSet rs = st.executeQuery();
while (rs.next()) {
    System.out.print("Column 1 returned ");
    System.out.println(rs.getString(1));
}
rs.close();
st.close()

注：?代表变量赋值的地方，变量索引从1开始

 2.使用cursor，来分页读取ResultSet，也就是说不用一次把所有查询结果提入内存。

conn.setAutoCommit(false);
Statement st = conn.createStatement();

// Turn use of the cursor on.
st.setFetchSize(50);
ResultSet rs = st.executeQuery("SELECT * FROM mytable");
while (rs.next()) {
   System.out.print("a row was returned.");
}
rs.close();

// Turn the cursor off.
st.setFetchSize(0);
rs = st.executeQuery("SELECT * FROM mytable");
while (rs.next()) {
   System.out.print("many rows were returned.");
}
rs.close();
st.close();

这个操作是隐式的，也就是说并不需要在程序逻辑上有什么显著的改变，它只是改变了运行的机制，也就是说在7-9行中，rs先查询50个结果，然后在while中运行50次，再向下查询50个结果，在运行50次while里的操作。而不用cursor时，rs会一次将所有结果都读入内存，如果返回的结果集特别大时这是无法运行的。

使用cursor需要几个条件：

(1) 使用V3 protocol，在7.4版本以后是默认设置

(2) Connection必须不是AutoCommit的，代码中第1行的设置：conn.setAutoCommit(false);

(3) Statement创建ResultSet时，必须使用ResultSet.TYPE_FORWARD_ONLY选项，这个设置时默认的

(4) query必须是一个单独的Statement，不能是多个Statement的总和。

(5) 另外还要设置Fetch的大小，在代码中第5行中设置，当将fetch的大小设置为0时，则表示一次全部读入。

3. 简单的Insert，Update，Delete等

在postgresql中，这些操作都需要使用PreparedStatement，就算是不需要变量的sql串。

    public  int Delete(Connection conn)
    {
        int rowsDeleted=0;
        PreparedStatement st;
        try {
            st = conn.prepareStatement("DELETE FROM mytable WHERE columnfoo = 500");
            rowsDeleted= st.executeUpdate();
        st.close();
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        return rowsDeleted;
    }
    public int Insert(Connection conn)
    {
        int rowsInsert=0;
        PreparedStatement st;
        try {
            st = conn.prepareStatement("INSERT INTO mytable(columnfoo,value) values(?,?)");
            st.setInt(1, 500);
            st.setDouble(2, 0.5);
            rowsInsert= st.executeUpdate();
        st.close();
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        return rowsInsert;        
    }

代码中写了两个简单的Insert和Delete例子，Update与其类似。

下面是一个最最简单的DBHelper

package wzy.db;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class DataHelper {
    
    public static Connection NewConnection(String database,String user,String password)
    {
        Connection conn=null;
         try {
                 Class.forName( "org.postgresql.Driver" ).newInstance();
                 
                 String url = "jdbc:postgresql://localhost:5432/"+database ;
                 
                 conn= DriverManager.getConnection(url, user , password );

        } catch (InstantiationException e) {
            e.printStackTrace();
        } catch (IllegalAccessException e) {
            e.printStackTrace();
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return conn;
    }
    public static ResultSet Select(Connection conn,String sql)
    {
        Statement st;
        ResultSet rs=null;
        try {
            st = conn.createStatement();
            rs=st.executeQuery(sql);
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return rs;
    }
    public static boolean InsertOrDeleteOrUpdate(Connection conn,String sql)
    {
        int row=0;
        try {
            PreparedStatement pst=conn.prepareStatement(sql);
            row=pst.executeUpdate();
            
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        return row>0;
    }
    public static boolean InsertOrDeleteOrUpdate(PreparedStatement pst) throws SQLException
    {
        return pst.executeUpdate()>0;
    }
}