connect.java

java编的销售系统

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.sql.Statement;

public class Connect {
    public static void getConnection()
	 {
    	  try
          {          
  				Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
  				connection= DriverManager.getConnection("jdbc:odbc:JAVA","123","123");
          } catch(ClassNotFoundException cnfex)
          {
              System.err.println("Load JDBC/ODBC driver failure");
              cnfex.printStackTrace();
          } catch(SQLException sqlex)
          {
              System.err.println("Can't connect server");
              sqlex.printStackTrace();
          }
       }

   	public static void addBakePizza(String pizzaType,String baseType,String topping,int sellType,int bakeCount,String bakeSpeed,int pizzaCost,double tax) throws SQLException
   	{
           String sql = "exec addBakePizza  " + pizzaType + ","+baseType+ ","+topping+","+sellType+","+bakeCount+","+bakeSpeed+","+pizzaCost+","+tax;
           //test sql
           System.out.println(sql);
           statement = connection.createStatement();
           statement.execute(sql);
           statement.close();
   	}
   	
	public static void addpizzabake(String basetype,String pizzatype,String topping,int sellway,int bakecount,String bakespeed,int totalcost,double tax) throws SQLException
	{
        String sql = "exec  addpizzabake " + basetype + ","+pizzatype+ ","+topping+","+sellway+","+bakecount+","+bakespeed+","+totalcost+","+tax;
        //test sql
        System.out.println(sql);
        statement = connection.createStatement();
        statement.execute(sql);
        statement.close();
	}
	
	
	public static void takepizza(String pizzatype,int quantity)throws SQLException
	{

		String sql = "exec takepizza  " + pizzatype + "," + quantity;
        //test sql
        System.out.println(sql);
        statement = connection.createStatement();
        statement.execute(sql);
       
        statement.close();
	}
	
	
	public static void addemployeejob(String employeeID,int workID) throws SQLException
	{
		String sql = "exec addemployeejob  " + employeeID + "," + workID;
        //test sql
        System.out.println(sql);
        statement = connection.createStatement();
        statement.execute(sql);
        statement.close();
		
	}
	
	public static void updatestore(String pizzatype,int basetype,int size,int quantity) throws SQLException
	{
		
		String sql = "exec updatestore  " + pizzatype + "," + basetype+","+size+","+quantity;
        //test sql
        System.out.println(sql);
        statement = connection.createStatement();
        statement.execute(sql);
        statement.close();
		
	}
	
	public static ResultSet checkquantity()throws SQLException
	{
		 
		String sql = "exec checkquantity ";
		System.out.println(sql);
        //test sql
        //System.out.println(sql);
        statement = connection.createStatement();
		ResultSet rs = statement.executeQuery(sql);
        return rs ;
		
	}
	
	public static ResultSet getnowlist()throws SQLException
	{
		
		String sql = "exec getnowlist ";
		System.out.println(sql);
        //test sql
        //System.out.println(sql);
        statement = connection.createStatement();
		ResultSet rs = statement.executeQuery(sql);
        return rs ;
		
	}
	
	public static ResultSet totalfee()throws SQLException
	{
		
		String sql = "exec totalfee ";
		System.out.println(sql);
        //test sql
        //System.out.println(sql);
		   statement = connection.createStatement();
		ResultSet rs = statement.executeQuery(sql);
        return rs ;
		
	}
	public static ResultSet employeewage() throws SQLException
	{
		String sql="exec employeewage ";
		System.out.println(sql);
//		test sql
        //System.out.println(sql);
		   statement = connection.createStatement();
		ResultSet rs = statement.executeQuery(sql);
        return rs ;
		
	}
	public int getQuantity(String pizzaType) throws SQLException
	{
        
        int returnCount = 0;
        String sql = "exec getQuantity " +pizzaType;
        //test sql
        //System.out.println(sql);
        statement = connection.createStatement();
		resultSet = statement.executeQuery(sql);
        
        while(resultSet.next())
			returnCount= resultSet.getInt(1);
        statement.close();
        return returnCount ;
	}	
	

	private String url =
        "jdbc:microsoft:sqlserver://localhost:1400;DatabaseName=JAVA";
private String username = "123";
private String password = "123";

private static Connection connection;
private static Statement statement;
private ResultSet resultSet;
private ResultSetMetaData rsMetaData;
}