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();
		}
	}

}