dbconnect.java

图书

package thizlinux.linuxhr;
import java.sql.*;
import javax.naming.*;
import javax.sql.*;

public class DBconnect{

	private Connection conn=null;
	private Statement stmt=null;
	private DataSource ds=null;
	private InitialContext ctx=null;
	private ResultSet rs=null;

	public DBconnect(){
		try{
		 	ctx=new InitialContext();
			ds=(DataSource)ctx.lookup("java:comp/env/jdbc/mysql");
			conn=ds.getConnection();
			stmt=conn.createStatement();
		}
		catch(SQLException e){
		   	System.out.println(e.getMessage());
		}
		catch(NamingException e){
		   	System.out.println(e.getMessage());
		}	
	}
	public ResultSet executeQuery(String sql){
		rs=null;
		try{
			if(stmt!=null){
				rs=stmt.executeQuery(pub.sqlchange(sql));
			}
		}
		catch(Exception ex){
	  		System.err.println(ex.getMessage()+",sql="+sql);
		}
	      return rs;	
	}

	public void executeUpdate(String sql) {
	   	try {
			if(stmt!=null){
				stmt.executeUpdate(pub.sqlchange(sql));
			}
		} 
		catch(Exception ex){
	   		System.err.println(ex.getMessage()+",sql="+sql);
	   	}
	}
    	public void close() {
		try {
			if(stmt!=null)stmt.close();
			if(conn!=null)conn.close();
		} catch (SQLException e) {
			System.out.println(e.getMessage());
		}
	}
}