tjdbc.java

来自「用java写的一个使用jdbc访问oracle数据库的接口类」· Java 代码 · 共 116 行

package com.nantian.tjdbc;

import java.sql.*;


/**   
*   
* @author ZhangMingxu   
*   
*/   
public class Tjdbc {   
   
    private String driver = "oracle.jdbc.driver.OracleDriver";       
    private String url = "";      
    private String user = "";   
    private String pwd = "";   
    
    private Connection conn = null;   
    private Statement statement = null; 
   
      
    public Tjdbc() {   
        init();   
    }   
   
    public Tjdbc(String driver, String url, String user, String pwd) {   
        this.driver = driver;   
        this.url = url;   
        this.user = user;   
        this.pwd = pwd;   
   
        init();   
    }   
   
    private void init() {      
        try {   
            Class.forName(driver);   
        } catch (ClassNotFoundException e) {      
            e.printStackTrace();   
        }   
   
        try {   
            conn = DriverManager.getConnection(url, user, pwd);   
            statement = conn.createStatement();   
        } catch (SQLException e) {     
            System.out.println("can not connect db!");   
            e.printStackTrace();   
        }   
    }   
      
    public ResultSet query(String sql) {   
        ResultSet rs = null;   
        try {   
            rs = statement.executeQuery(sql);   
        } catch (SQLException e) {     
            e.printStackTrace();   
        }   
        return rs;   
    }   
   
    public boolean execute(String hql) {   
        try {   
            return statement.execute(hql);   
        } catch (SQLException e) {    
            e.printStackTrace();   
        }   
        return false;   
    }   
   
    public void closeConnection() {   
        if (conn != null)   
            try {   
                conn.close();   
            } catch (SQLException e) {   
                e.printStackTrace();   
            }   
        if (statement != null)   
            try {   
                statement.close();   
            } catch (SQLException e) {   
                e.printStackTrace();   
            }   
    }

	public String getDriver() {
		return driver;
	}

	public void setDriver(String driver) {
		this.driver = driver;
	}

	public String getPwd() {
		return pwd;
	}

	public void setPwd(String pwd) {
		this.pwd = pwd;
	}

	public String getUrl() {
		return url;
	}

	public void setUrl(String url) {
		this.url = url;
	}

	public String getUser() {
		return user;
	}

	public void setUser(String user) {
		this.user = user;
	}   
}