连接数据库postgresql

xiahe999

package com.zyna.db;
import java.sql.*;
import java.util.logging.Level;
import java.util.logging.Logger;
import sun.applet.Main;
/**
*
* @author Administrator
*/
public class DbAccessor {
private Connection conn;
private Statement stmt;
//boco server posgresql
private String hostIp="10.0.3.40";
//local
//private String hostIp="localhost";
private String port="5432";
private String dbName="smp_main";
//server
private String dbAdmin="smp";
//private String dbAdmin="postgres";
//
//boco server posgresql
private String dbPassword="smpboco";
//local
// private String dbPassword="orcl";

//    Class.forName("org.postgresql.Driver").newInstance();   
//    String   url   ="jdbc:postgresql://localhost/myDB"   
//    //myDB为数据库名   
//    String   user="myuser";   
//    String   password="mypassword";   
//    Connection   conn=   DriverManager.getConnection(url,user,password);
//  请给我个完整的代码,我在数据库里建了一个库叫harddisk,
//   

private void getConnection() {
try {
// TODO code application logic here
//加载驱动
//Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
//Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");
Class.forName("org.postgresql.Driver");
try {
//连接数据库
//                conn = DriverManager.getConnection("jdbc:sqlserver://" + hostIp + ":"
//                        + port + ";databaseName=" + dbName, dbAdmin, dbPassword);
String str = "jdbc:postgresql://" + hostIp + ":"+ port + ";databaseName=" + dbName;
System.out.println("str-->"+str);
conn = DriverManager.getConnection("jdbc:postgresql://" + hostIp + ":"+ port + "/" + dbName, dbAdmin, dbPassword);
} catch (SQLException ex) {
Logger.getLogger(Main.class.getName()).log(Level.SEVERE, null, ex);
System.out.println("数据库连接失败！！");
}
} catch (ClassNotFoundException ex) {
Logger.getLogger(Main.class.getName()).log(Level.SEVERE, null, ex);
System.out.println("数据库驱动程序加载失败！");
}
}

public ResultSet execute(String sql){
try{
if(conn==null){
getConnection();
}
//创建Statement对象
stmt = conn.createStatement();
try {
//将SQL字符串送给Statement执行
ResultSet rs;
//如果SQL语句是SELECT语句
if(sql.substring(0, 6).equalsIgnoreCase("select")){
rs= stmt.executeQuery(sql);
return rs;
} else{
stmt.executeUpdate(sql);
return null;
}
} catch (SQLException ex) {
System.out.println("SQL语句执行错误！！！");
System.out.println(sql);
}
} catch (SQLException ex) {
System.out.println("创建Statement失败！！");
}
return null;
}
public void close() {
try {
stmt.close();
conn.close();
} catch (SQLException ex) {
Logger.getLogger(DbAccessor.class.getName()).log(Level.SEVERE, null, ex);
}
}

public static void main(String[] args){

DbAccessor dbAccessor = new DbAccessor();

dbAccessor.getConnection();

}
}