dbbean.java

饲料公司销售管理系统是基于建立完善的饲料公司销售方面管理控制模型的基础上

package sale;
import java.io.*; 
import java.sql.*; 

public class dbBean{

	public Connection conn=null; 
	public Statement stmt=null;
	public ResultSet rs=null; 
	//private String DatabaseDriver="sun.jdbc.odbc.JdbcOdbcDriver"; 
	private String DatabaseDriver="com.microsoft.jdbc.sqlserver.SQLServerDriver";
	//private String dburl="jdbc:odbc:sale";
	private String dburl="jdbc:microsoft:sqlserver://localhost:1433;DatabaseName=sale";
	public dbBean()
	{
		try{ 
			//Class.forName(DatabaseDriver);
			Class.forName(DatabaseDriver).newInstance();
			} 
		catch(java.lang.ClassNotFoundException e){ 
			System.err.println("加载驱动器有错误:"+e.getMessage( ));  
		} 
	} 

	public void setDatabaseDriver(String Driver)
	{ 
		this.DatabaseDriver=Driver; 
	} 
	
	public String getDatabaseDriver()
	{ 
		return (this.DatabaseDriver); 
	} 
	
	public void setDburl(String dburl)
	{ 
		this.dburl=dburl; 
	} 
	
	public String getDburl()
	{ 
		return (this.dburl); 
	} 
	                 
	public void executeInsert(String sql)
	{ 
		try{ 
			//conn = DriverManager.getConnection(dburl);
			conn = DriverManager.getConnection(dburl,"","");
			//stmt=conn.createStatement( ); 
			stmt=conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_UPDATABLE );
			stmt.executeUpdate(sql); 
			} 
		catch(SQLException ex){ 
			System.out.print("执行插入有错误:"+ex.getMessage());
		}finally{			
			close();
			}
	} 

	public ResultSet executeQuery(String sql)
	{ 
		rs=null; 
		try{ 
			//conn = DriverManager.getConnection(dburl);
			conn = DriverManager.getConnection(dburl,"","");
			//stmt=conn.createStatement( ); 
			stmt=conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_UPDATABLE );
			rs=stmt.executeQuery(sql);
		} 
		catch(SQLException ex){ 
			System.out.print("执行查询有错误:"+ex.getMessage());
		}
		return rs; 
	} 

	public void executeDelete(String sql)
	{ 
		try{ 
			//conn=DriverManager.getConnection(dburl);
			conn = DriverManager.getConnection(dburl,"","");
			//stmt=conn.createStatement( ); 
			stmt=conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_UPDATABLE );
			stmt.executeUpdate(sql); 
		} 
		catch(SQLException ex){ 
			System.out.print("执行删除有错误:"+ex.getMessage()); 
		} finally{
			close();
		}
	} 

	public void close()
	{ 
		try{ 
			if(rs!=null)
			{
				rs.close();
				rs=null;
			}
			if(stmt!=null)
			{
				stmt.close();
				stmt=null;
			}
			if(conn!=null)
			{
				conn.close();
				conn=null;
			} 
		} 
		catch(Exception end){ 
			System.out.print("执行执行关闭Connection对象有错误：有错误:"+end.getMessage()); 
		} 
	} 
}