sqlbean.java

来自「JAVA+飞机订票系统源代码」· Java 代码 · 共 110 行

package flight.assist;

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

public class SqlBean
{
	private Connection conn=null;
	private ResultSet rs=null;
	   //Database driver
	private String DatabaseDriver="sun.jdbc.odbc.JdbcOdbcDriver";
	   //Database sourse 
	private String DatabaseConnStr="jdbc:odbc:dsStudent";
	   //ID to login
	private String LogId="sa";
	   //Password to login
	private String LogPass="";
	
	   //Constructor method
	public SqlBean()
	{
		try
		{
			Class.forName(DatabaseDriver);
		}
		catch(ClassNotFoundException e)
		{
		}
	}
	   
	   //select
	public ResultSet executeQuery(String sql)
	{
		rs=null;
		try
		{
			conn = DriverManager.getConnection(DatabaseConnStr,LogId,LogPass);
			Statement stmt=conn.createStatement();
			rs=stmt.executeQuery(sql);
		}
		catch(SQLException ex)
		{		
		}
	
		return rs;
	}
	   
	   //insert
	public int executeInsert(String sql)
	{
		int num=0;
		try
		{
			conn = DriverManager.getConnection(DatabaseConnStr,LogId,LogPass);
			Statement stmt=conn.createStatement();
			num=stmt.executeUpdate(sql);
		}
		catch(SQLException ex)
		{
		}
		
		return num;
	} 
	   
	   //delete
	public int executeDelete(String sql)
	{
		int num=0;
		try
		{
			conn = DriverManager.getConnection(DatabaseConnStr,LogId,LogPass);
			Statement stmt=conn.createStatement();
			num=stmt.executeUpdate(sql);
		}
		catch(SQLException e)
		{
		}
	
		return num;
	}
	
	   //update
	public int executeUpdate(String sql)
	{
		int num=0;
		try
		{
			conn = DriverManager.getConnection(DatabaseConnStr,LogId,LogPass);
			Statement stmt=conn.createStatement();
			num=stmt.executeUpdate(sql);
		}
		catch(SQLException e)
		{
		}
	
		return num;
	}
	   
	   //close
	public void CloseDataBase()
	{
		try
		{
			conn.close();
		}
		catch(Exception e)
		{
		}
	}
}///:~