Java利用JDBC连接数据库

  1package test.capture;
  2
  3import java.sql.Connection;
  4import java.sql.DriverManager;
  5import java.sql.ResultSet;
  6import java.sql.SQLException;
  7import java.sql.Statement;
  8
  9public class DBAccess {
 10    /**
 11     * connection parameters
 12     */
 13    private Connection conn;
 14    private Statement stmt;
 15    String driver = "oracle.jdbc.driver.OracleDriver";
 16    String url = "jdbc:oracle:thin:@192.168.0.117:1521:QEWAY";
 17    String userName = "hangfatest";
 18    String password = "hangfatest";
 19    public Connection getConn() {
 20        return conn;
 21    }
 22    public void setConn(Connection conn) {
 23        this.conn = conn;
 24    }
 25    public Statement getStmt() {
 26        return stmt;
 27    }
 28    public void setStmt(Statement stmt) {
 29        this.stmt = stmt;
 30    }
 31    
 32    public DBAccess(){
 33        this.setDriver(driver);
 34        this.setConnection(url, userName, password);
 35    }
 36    public DBAccess(String driver, String url, String userName, String password){
 37        try{
 38            conn = DriverManager.getConnection(url,userName,password);
 39            stmt = conn.createStatement();
 40        }catch(SQLException e){
 41            e.printStackTrace();
 42        }
 43    }
 44    
 45    /**
 46     * setDriver
 47     */
 48    public boolean setDriver(String driver){
 49        try{
 50            Class.forName(driver);
 51            return true;
 52        }catch(Exception e){
 53            e.printStackTrace();
 54        }
 55        return false;
 56    }
 57    /**
 58     * setConnection
 59     */
 60    public boolean setConnection(String url, String userName, String password){
 61        try{
 62            conn = DriverManager.getConnection(url,userName,password);
 63            stmt = conn.createStatement();
 64            return true;
 65        }catch(Exception e){
 66            e.printStackTrace();
 67        }
 68        return false;
 69    }
 70    /**
 71     * 处理查询
 72     */
 73    public ResultSet sendQuery(String sql){
 74        try{
 75            ResultSet rs = stmt.executeQuery(sql);
 76            return rs;
 77        }catch(SQLException e){
 78            e.printStackTrace();
 79            return null;
 80        }
 81    }
 82    /**
 83     * 处理数据更新
 84     */
 85    public int sendUpdate(String sql){
 86        try{
 87            return stmt.executeUpdate(sql);
 88        }catch(SQLException e){
 89            e.printStackTrace();
 90            return -1;
 91        }
 92    }
 93    
 94    /**
 95     * main TEST
 96     */
 97    public static void main(String[] args) {
 98        DBAccess db = new DBAccess();
 99        String sql = "select * from SYS_BILL_NO";
100        ResultSet rs = db.sendQuery(sql);
101        try{
102            if(rs != null){
103                while(rs.next()){
104                    System.out.println(rs.getString("KEY_NAME")+ "  " + 
105                            rs.getString("NEXT_VALUE"));
106                }
107            }
108        }catch(Exception e){
109            e.printStackTrace();
110        }
111        
112    }    
113}
114

posted on 2009-07-16 18:57 彭伟 阅读(149) 评论(0)  编辑  收藏 所属分类: java技术分区


只有注册用户登录后才能发表评论。
网站导航:
 
<2009年7月>
日一二三四五六
2829301234
567891011
12131415161718
19202122232425
2627282930311
2345678

导航

统计

常用链接

留言簿(3)

随笔分类

随笔档案

搜索

最新评论

阅读排行榜

评论排行榜