dbconnect.java

jsp+oracle书记的源代码

package net.acai.database;

import java.sql.*;
import net.acai.database.DBConnectionManager;

/**
 * Title:        清清网络
 * Description:
 * Copyright:    Copyright (c) 2002
 * Company:      211.68.39.120、webcpu.51.net
 * @author:       SuperSpace
 * @version 1.0
 */

public class DBConnect {
	private Connection conn = null;
	private Statement stmt = null;
	private PreparedStatement prepstmt = null;
	private String DatabaseDriver="oracle.jdbc.driver.OracleDriver"; 
	private String DatabaseConnStr="jdbc:oracle:thin:@222.28.39.246:1521:hgbj,'message',message";
	private String strcon = "jdbc:oracle:thin:@222.28.39.246:1521:hgbj";
    /*void init() {
		try{
        //dcm = DBConnectionManager.getInstance();
		//conn = dcm.getConnection("mysql");
		conn = DriverManager.getConnection(strcon,"message","message");
		stmt = conn.createStatement( );
		ResultSet rstemp = stmt.executeQuery("select * from config");
		while (rstemp.next()){
			System.out.println("========="+rstemp.getString(1));
		}
		}catch(SQLException ex){ 
			System.err.println("创建连接出错:"+ex.getMessage() ); 
			System.out.print("创建连接出错:"+ex.getMessage());//输出到客户端 
		}
    }*/

	/**
	 * 构造数据库的连接和访问类
	 */
	public DBConnect() throws Exception {
		try{ 
			Class.forName(DatabaseDriver); 
		} 
		catch(java.lang.ClassNotFoundException e){ 
			System.err.println("加载驱动器有错误:"+e.getMessage( )); 
			System.out.print("执行插入有错误:"+e.getMessage());//输出到客户端 
		} 
		conn = DriverManager.getConnection(strcon,"message","");
        //init();
		stmt = conn.createStatement();
	}

    public DBConnect(int resultSetType, int resultSetConcurrency)
            throws Exception {
		try{ 
			Class.forName(DatabaseDriver); 
		} 
		catch(java.lang.ClassNotFoundException e){ 
			System.err.println("加载驱动器有错误:"+e.getMessage( )); 
			System.out.print("执行插入有错误:"+e.getMessage());//输出到客户端 
		} 
        conn = DriverManager.getConnection(strcon,"message","message");
        stmt = conn.createStatement(resultSetType, resultSetConcurrency);
    }

    /**
     * 构造数据库的连接和访问类
     * 预编译SQL语句
     * @param sql SQL语句
     */
	public DBConnect(String sql) throws Exception {
		try{ 
			Class.forName(DatabaseDriver); 
		} 
		catch(java.lang.ClassNotFoundException e){ 
			System.err.println("加载驱动器有错误:"+e.getMessage( )); 
			System.out.print("执行插入有错误:"+e.getMessage());//输出到客户端 
		} 
		System.out.println("=============DBConnect1111");
        conn = DriverManager.getConnection(strcon,"test","test");
		Statement stmtemp = conn.createStatement( );
		ResultSet rstemp = stmt.executeQuery("select * from student");
		while (rstemp.next()){
			System.out.println("========="+rstemp.getString(1));
		}

		System.out.println("=============DBConnect22222");
		this.prepareStatement(sql);
		System.out.println("=============DBConnect33333");
	}

	public DBConnect(String sql, int resultSetType, int resultSetConcurrency)
            throws Exception {
		try{ 
			Class.forName(DatabaseDriver); 
		} 
		catch(java.lang.ClassNotFoundException e){ 
			System.err.println("加载驱动器有错误:"+e.getMessage( )); 
			System.out.print("执行插入有错误:"+e.getMessage());//输出到客户端 
		} 
        conn = DriverManager.getConnection(strcon,"message","message");
		this.prepareStatement(sql, resultSetType, resultSetConcurrency);
	}

	/**
	 * 返回连接
	 * @return Connection 连接
	 */
	public Connection getConnection() {
		return conn;
	}

	/**
	 * PreparedStatement
	 * @return sql 预设SQL语句
	 */
	public void prepareStatement(String sql) throws SQLException {
		System.out.println("=======prepareStatement");
		prepstmt = conn.prepareStatement(sql);
	}

	public void prepareStatement(String sql, int resultSetType, int resultSetConcurrency)
            throws SQLException {
		prepstmt = conn.prepareStatement(sql, resultSetType, resultSetConcurrency);
	}

	/**
	 * 设置对应值
     *
	 * @param index 参数索引
	 * @param value 对应值
	 */
	public void setString(int index,String value) throws SQLException {
		prepstmt.setString(index, value);
	}
	public void setInt(int index,int value) throws SQLException {
		prepstmt.setInt(index,value);
	}
	public void setBoolean(int index,boolean value) throws SQLException {
		prepstmt.setBoolean(index,value);
	}
	public void setDate(int index,Date value) throws SQLException {
		prepstmt.setDate(index,value);
	}
	public void setLong(int index,long value) throws SQLException {
		prepstmt.setLong(index,value);
	}
	public void setFloat(int index,float value) throws SQLException {
		prepstmt.setFloat(index,value);
	}
	public void setBytes(int index,byte[] value) throws SQLException{
		prepstmt.setBytes(index,value);
	}
	 


    public void clearParameters()
        throws SQLException
    {
        prepstmt.clearParameters();
	prepstmt=null;
    }
	/**
	 * 返回预设状态
	 */
	public PreparedStatement getPreparedStatement() {
		return prepstmt;
	}
	/**
	 * 返回状态
	 * @return Statement 状态
	 */
	public Statement getStatement() {
		return stmt;
	}
	/**
	 * 执行SQL语句返回字段集
	 * @param sql SQL语句
	 * @return ResultSet 字段集
	 */
	public ResultSet executeQuery(String sql) throws SQLException {
		System.out.println("executeQuery11111111111");
		if (stmt != null) {
			System.out.println("executeQuery11111111111");
			return stmt.executeQuery(sql);
		}
		else return null;
	}

	public ResultSet executeQuery() throws SQLException {
		if (prepstmt != null) {
			return prepstmt.executeQuery();
		}
		else return null;
	}

	/**
	 * 执行SQL语句
	 * @param sql SQL语句
	 */
	public void executeUpdate(String sql) throws Exception {
		if (stmt != null)
			stmt.executeUpdate(sql);
		close();
	}
	public void executeUpdate() throws Exception {
		if (prepstmt != null)
			prepstmt.executeUpdate();
		close();
	}
	/**
	 * 关闭连接
	 */
	public void close() throws Exception {
		if (stmt != null)  {
			stmt.close();
			stmt = null;
		}
		if (prepstmt != null) {
			prepstmt.close();
			prepstmt = null;
		}
		if (conn!=null)
		{
			//dcm.freeConnection("mysql",conn);
			conn.close();
		}
		
	}
}