dbbean.java

java swing源码 欢迎下载 有问题请联系 我一定负责到底

package com.sinosoft.common;

import java.io.InputStream;
import java.sql.*;

import javax.naming.NamingException;
import javax.sql.*;

public class DbBean {
	public java.sql.Connection conn = null; // connection object
	public java.sql.Connection con = null;
	public ResultSet rs = null; // resultset object

	public Statement stmt = null; // statement object

	public PreparedStatement prepstmt = null; // preparedstatement object

//	private String drivers = null; // connection parameter:drivers
//
//	private String url = null; // connection parameter:url
//
//	private String user = null; // connection parameter:user
//
//	private String password = null; // connection parameter:password
	private static DataSource dataSource = null; 
	private static javax.naming.InitialContext ctx;
	static String jndiName="NCL";
	/**
	 * init()
	 */
	public DbBean() {
		try {
			// parameter init
//			drivers = "com.microsoft.jdbc.sqlserver.SQLServerDriver";
//			url = "jdbc:microsoft:sqlserver://localhost:1433;DatabaseName=EAM;SelectMethod=cursor";
//			user = "sa";
//			password = "1";

			// db connection pool init
			// InitialContext env = new InitialContext();
			// javax.sql.DataSource pool =
			// (javax.sql.DataSource)env.lookup(jndi_name);
			// conn = pool.getConnection();

			// db connection init
			//Class.forName(drivers);
			conn = DataConPool.getConnection();
			//conn = getConnectionByPool();
			// db statement init
			//stmt = conn.createStatement();
		} catch (Exception e) {
			System.out.println("dbBean: init error!" + e.toString());
		}
	}
	
	public static Connection getConnectionByPool() throws Exception{
		if(dataSource==null){
			try{
				ctx = new javax.naming.InitialContext();
				dataSource = ((javax.sql.DataSource) ctx.lookup(jndiName));			
			} catch (NamingException e) {
				System.out.println("getConnection error:"+e.getMessage());
				throw new Exception("not find the datasource:" + jndiName);
			}
		}	
		if (dataSource.getConnection() == null) {
			throw new Exception("Newly allocated connection is null");
		}else
			return dataSource.getConnection();
	}

	/**
	 * @function prepareStatement
	 * @param sql
	 *            String
	 * @throws SQLException
	 */
	public void prepareStatement(String sql) throws SQLException {
		prepstmt = conn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_UPDATABLE);
	}

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

	/**
	 * @function executeQuery
	 * @param sql
	 *            String
	 * @throws SQLException
	 * @return ResultSet
	 */
	public ResultSet executeQuery(String sql) throws SQLException {
		if (stmt != null) {
			return stmt.executeQuery(sql);
		} else
			return null;
	}

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

	/**
	 * @function executeUpdate
	 * @param sql
	 *            String
	 * @throws SQLException
	 */
	public void executeUpdate(String sql) throws SQLException {
		if (stmt != null)
			stmt.executeUpdate(sql);
	}

	/**
	 * @function executeUpdate
	 * @throws SQLException
	 */
	public void executeUpdate() throws SQLException {
		if (prepstmt != null)
			prepstmt.executeUpdate();
	}
	
	/**
	 * @function executeUpdate
	 * @throws SQLException
	 */
	public boolean execute() throws SQLException {
		if (prepstmt != null){
			prepstmt.execute();
			return true;
		}
		else return false;
	}

	/**
	 * @function executeUpdate
	 * @throws SQLException
	 */
	public void executeBatch() throws SQLException {
		if (prepstmt != null)
			prepstmt.executeBatch();
	}

	/**
	 * @function addBatch
	 * @param value
	 *            String
	 * @throws SQLException
	 */
	public void addBatch(String value) throws SQLException {
		prepstmt.addBatch(value);
	}
	
	/**
	 * @function addBatch
	 * @throws SQLException
	 */
	public void addBatch() throws SQLException {
		prepstmt.addBatch();
	}

	/**
	 * @function setString
	 * @param index
	 *            int
	 * @param value
	 *            String
	 * @throws SQLException
	 */
	public void setString(int index, String value) throws SQLException {
		prepstmt.setString(index, value);
	}

	/**
	 * @function setInt
	 * @param index
	 *            int
	 * @param value
	 *            int
	 * @throws SQLException
	 */
	public void setInt(int index, int value) throws SQLException {
		prepstmt.setInt(index, value);
	}

	/**
	 * @function setBoolean
	 * @param index
	 *            int
	 * @param value
	 *            boolean
	 * @throws SQLException
	 */
	public void setBoolean(int index, boolean value) throws SQLException {
		prepstmt.setBoolean(index, value);
	}

	/**
	 * @function setDate
	 * @param index
	 *            int
	 * @param value
	 *            Date
	 * @throws SQLException
	 */
	public void setDate(int index, Date value) throws SQLException {
		prepstmt.setDate(index, value);
	}

	/**
	 * @function setLong
	 * @param index
	 *            int
	 * @param value
	 *            long
	 * @throws SQLException
	 */
	public void setLong(int index, long value) throws SQLException {
		prepstmt.setLong(index, value);
	}

	/**
	 * @function setFloat
	 * @param index
	 *            int
	 * @param value
	 *            float
	 * @throws SQLException
	 */
	public void setFloat(int index, float value) throws SQLException {
		prepstmt.setFloat(index, value);
	}

	/**
	 * @function setBytes
	 * @param index
	 *            int
	 * @param value
	 *            byte[]
	 * @throws SQLException
	 */
	public void setBytes(int index, byte[] value) throws SQLException {
		prepstmt.setBytes(index, value);
	}

	/**
	 * @function setBinaryStream
	 * @param index
	 *            int
	 * @param value
	 *            InputStream
	 * @param len
	 *            int
	 * @throws SQLException
	 */
	public void setBinaryStream(int index, InputStream value, int len)
			throws SQLException {
		prepstmt.setBinaryStream(index, value, len);
	}

	/**
	 * @function setTimestamp
	 * @param index
	 *            int
	 * @param timestamp
	 *            Timestamp
	 * @throws SQLException
	 */
	public void setTimestamp(int index, Timestamp timestamp)
			throws SQLException {
		prepstmt.setTimestamp(index, timestamp);
	}

	/**
	 * @function setAutoCommit
	 * @param value
	 *            boolean
	 * @throws SQLException
	 */
	public void setAutoCommit(boolean value) throws SQLException {
		if (this.conn != null)
			this.conn.setAutoCommit(value);
	}

	/**
	 * @function commit
	 * @throws SQLException
	 */
	public void commit() throws SQLException {
		this.conn.commit();
	}

	/**
	 * @function rollback
	 * @throws SQLException
	 */
	public void rollback() throws SQLException {
		this.conn.rollback();
	}

	/**
	 * @function close
	 * @throws Exception
	 */
	public void close() {
		try {
			if (rs != null) {
				rs.close();
				rs = null;
			}
		} catch (Exception e) {
			System.out.println("dbBean close rs error!");
		} finally {
			try {
				if (stmt != null) {
					stmt.close();
					stmt = null;
				}
			} catch (Exception e) {
				System.out.println("dbBean close stmt error!");
			} finally {
				try {
					if (prepstmt != null) {
						prepstmt.close();
						prepstmt = null;
					}
				} catch (Exception e) {
					System.out.println("dbBean close prepstmt error!");
				} finally {
					try {
						if (conn != null) {
							conn.close();
							conn = null;
						}
					} catch (Exception e) {
						System.out.println("dbBean close conn error!");
					}
				}
			}
		}
	}

}