operation_server.java

本系统为六合彩网上投注系统

package operation;

// 业务流程处理类 --- 服务器端
import java.sql.*;

public class Operation_server
{
  private Connection conn;
  private Statement stmt;
  private PreparedStatement pstmt;
  private final String url = "jdbc:mysql://localhost:3306/liuhecai";

  public Operation_server()
  {
  }

  // 验证管理员身份方法
  public boolean validate(String username,String password)
  {
    try
    {
      Class.forName("org.gjt.mm.mysql.Driver");
      conn = DriverManager.getConnection(url);
      stmt = conn.createStatement();
      ResultSet rs = stmt.executeQuery("select * from adminInfo where username='"+username+"' and password='"+password+"'");
      if(rs.next())
      {
        return true;
      }
      else
      {
        return false;
      }
    }
    catch (Exception ex)
    {
      ex.printStackTrace();
      return false;
    }
  }

  //开奖结果
  public boolean result(int nowQiNum,int oneNum,int twoNum,int threeNum,int fourNum,int fiveNum,int sixNum,int speNum)
  {
    try
    {
      String sql = "insert into result values(?,?,?,?,?,?,?,?)";
      String sql2 = "update nowQiNum set nowQiNum='" + nowQiNum + "'";
      Class.forName("org.gjt.mm.mysql.Driver");
      conn = DriverManager.getConnection(url);
      stmt = conn.createStatement();
      int re2 = stmt.executeUpdate(sql2);
      pstmt = conn.prepareStatement(sql);
      pstmt.setInt(1,nowQiNum);
      pstmt.setInt(2,oneNum);
      pstmt.setInt(3,twoNum);
      pstmt.setInt(4,threeNum);
      pstmt.setInt(5,fourNum);
      pstmt.setInt(6,fiveNum);
      pstmt.setInt(7,sixNum);
      pstmt.setInt(8,speNum);
      int re = pstmt.executeUpdate();
      if(re != 0 && re2 != 0)
      {
        return true;
      }
      return false;
    }
    catch (Exception ex)
    {
      ex.printStackTrace();
      return false;
    }
  }

  // 根据输入期号查询最新的投注
  public ResultSet searchNewChipIn(int qiNum) throws ClassNotFoundException,
      SQLException {
    Class.forName("org.gjt.mm.mysql.Driver");
    conn = DriverManager.getConnection(url);
    stmt = conn.createStatement();
    String sql = "select * from lottery where qiNum="+qiNum;
    ResultSet rs = stmt.executeQuery(sql);
    return rs;
  }

  // 本期 奖金金额 公布
  public String resultMoney(int nowQiNum,String headMoney,String twoMoney,
  String threeMoney,String fourMoney,String fiveMoney,String sixMoney,String sevenMoney)
  {
    try
    {
      String sql = "insert into resultMoney values(?,?,?,?,?,?,?,?)";
      Class.forName("org.gjt.mm.mysql.Driver");
      conn = DriverManager.getConnection(url);
      pstmt = conn.prepareStatement(sql);
      pstmt.setInt(1,nowQiNum);
      pstmt.setString(2,headMoney);
      pstmt.setString(3,twoMoney);
      pstmt.setString(4,threeMoney);
      pstmt.setString(5,fourMoney);
      pstmt.setString(6,fiveMoney);
      pstmt.setString(7,sixMoney);
      pstmt.setString(8,sevenMoney);
      int re = pstmt.executeUpdate();
      if(re != 0)
      {
        return "success";
      }
      return "success";
    }
    catch (Exception ex)
    {
      ex.printStackTrace();
      return "fail";
    }
  }
}