www.pudn.com > BeiJie.rar > DataBase.java

package dataBase; 
 
import java.sql.CallableStatement; 
import java.sql.Connection; 
import java.sql.DriverManager; 
import java.sql.ResultSet; 
import java.sql.SQLException; 
import java.sql.Statement; 
import java.sql.Types; 
import java.util.ArrayList; 
import java.util.Iterator; 
import java.util.Vector; 
 
import entity.EnterCheckView; 
 
public class DataBase 
{ 
	private Connection conn = null; 
	private Statement stmt = null; 
	private ResultSet rs = null; 
 
	public DataBase() 
	{ 
		String CLASSFORNAME = "org.gjt.mm.mysql.Driver"; 
		String SERVANDDB = "jdbc:mysql://localhost:3306/BeiJie?" 
				+ "user=root&password=123456&useUnicode=true&characterEncoding=gb2312"; 
 
		try 
		{ 
			Class.forName(CLASSFORNAME); 
			conn = DriverManager.getConnection(SERVANDDB); 
 
		} 
 
		catch (Exception e) 
		{ 
			e.printStackTrace(); 
		} 
	} 
 
	public void ExeQuery(String sql) 
	{ 
		try 
		{ 
			stmt = conn.createStatement(); 
			stmt.executeUpdate(sql); 
			stmt.close(); 
		} catch (Exception e) 
		{ 
			e.printStackTrace(); 
		} 
	} 
 
	public void ExeQuery(String sql1, String sql2,String sql3) 
	{ 
		try 
		{ 
			conn.setAutoCommit(false); 
			stmt = conn.createStatement(); 
			stmt.executeUpdate(sql1); 
			stmt.executeUpdate(sql2); 
			if(sql3!=null) 
			stmt.executeUpdate(sql3); 
			conn.commit(); 
			stmt.close(); 
		} catch (Exception e) 
		{ 
			e.printStackTrace(); 
		} 
	} 
	public void ExeQuery(String sql1,String sql2,String sql3,ArrayList list,String SaleID) 
	{ 
		String sql; 
		try 
		{ 
			conn.setAutoCommit(false); 
			stmt = conn.createStatement(); 
			stmt.executeUpdate(sql1); 
			stmt.executeUpdate(sql2); 
			stmt.executeUpdate(sql3); 
			Iterator it=list.iterator(); 
			while(it.hasNext()) 
			{ 
				EnterCheckView ecv=(EnterCheckView)it.next(); 
				String EnterID=ecv.getEnterID(); 
				int EnterQuantity=ecv.getEnterQuantity(); 
			    sql="insert into SaleDetailInfo values(default,'"+EnterID+"','"+SaleID+"',"+EnterQuantity+")"; 
			    stmt.execute(sql); 
			} 
			conn.commit(); 
			stmt.close(); 
		} catch (Exception e) 
		{ 
			e.printStackTrace(); 
		} 
	} 
 
	public ResultSet getResult(String sql) 
	{ 
		rs = null; 
		try 
		{ 
			stmt = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); 
			rs = stmt.executeQuery(sql); 
			return rs; 
 
		} catch (Exception e) 
		{ 
			e.printStackTrace(); 
		} 
		return null; 
	} 
	public Vector  getFinancialInfo(String starttime,String endtime) throws SQLException 
	{ 
		String sql_text="{call financecheck(?,?,?,?);}"; 
		CallableStatement statementName = conn.prepareCall(sql_text); 
		statementName.setString(1, starttime); 
		statementName.setString(2, endtime); 
		statementName.registerOutParameter(3,Types.FLOAT); 
		statementName.registerOutParameter(4,Types.FLOAT); 
		statementName.execute(); 
		Vector vector=new Vector(); 
		vector.add(0,statementName.getFloat(3)); 
		vector.add(1,statementName.getFloat(4)); 
		return vector; 
	} 
	public void close() 
	{ 
		try 
		{ 
			rs.close(); 
			stmt.close(); 
			conn.close(); 
		} catch (SQLException e) 
		{ 
			// TODO Auto-generated catch block 
			e.printStackTrace(); 
		} 
	} 
	public void shut() 
	{ 
		try 
		{ 
			stmt.close(); 
			conn.close(); 
		} catch (SQLException e) 
		{ 
			// TODO Auto-generated catch block 
			e.printStackTrace(); 
		} 
	} 
 
}