cartdata.java~5~

购物车模块实例。购物车模块可以浏览商品类别；可以根据商品类别浏览商品信息；可以购买商品；可以查看购物车的商品；可以修改购买商品的数量和删除购买的商品。

package data;

import java.sql.*;

public class CartData {

  //取得数据库联接的方法
  public Connection setupConn(){
    try{
      //定义MySQL的数据库联接驱动类
      String mySqlDriver = "org.gjt.mm.mysql.Driver";
      //定义MySQL的连接地址
      String url = "jdbc:mysql://localhost:3306/Infor?user=root;password=";
      //使用JDBC桥创建数据库联接
      Class.forName(mySqlDriver);
      //使用DriverManager类的getConnection()方法建立联接,
      //第一个字符参数定义用户名,第二个字符参数定义密码
      Connection conn = DriverManager.getConnection(url, "", "");
      return conn;
    }catch(Exception e){
      e.printStackTrace();
      return null;
    }
  }
  //取得产品类别数据的方法
  public String[][] getCategory(){
    //创建存取产品类别数据表数据的数组
    String[][] categories = null;
    //取得Infor数据库的联接
    Connection conn = setupConn();
    int rowCount = 0;
    try{
      //创建SQL语句执行类
      Statement stmt = conn.createStatement();
      String sql = "select count(*) from category";
      ResultSet rs = stmt.executeQuery(sql);
      //取得总记录数
      if(rs.next()){
        rowCount = rs.getInt(1);
      }
      if(rowCount > 0){
        //根据总记录数创建数组
        categories = new String[rowCount][3];
        sql = "select * from category";
        rs = stmt.executeQuery(sql);
        int row = 0;
        while(rs.next()){
          //取得类别ID
          categories[row][0] = rs.getString(1);
          //取得类别名字
          categories[row][1] = rs.getString(2);
          //取得类别描述
          categories[row][2] = rs.getString(3);
          row++;
        }
      }else{
        categories = new String[1][1];
        categories[0][0] = "没有产品类别数据.";
      }
      stmt.close();
    }catch(Exception ex){
      ex.printStackTrace();
    }
    //关闭数据库的联接
    closeConn(conn);
    return categories;
  }

  //根据产品类别取得产品数据的方法
  public String[][] getProduct(int categoryId){
    //创建存取产品数据表数据的数组
    String[][] products = null;
    //取得Infor数据库的联接
    Connection conn = setupConn();
    int rowCount = 0;
    try{
      //创建SQL语句执行类
      Statement stmt = conn.createStatement();
      String sql = "select count(*) from product where categoryId = " + categoryId;
      ResultSet rs = stmt.executeQuery(sql);
      //取得总记录数
      if(rs.next()){
        rowCount = rs.getInt(1);
      }
      if(rowCount > 0){
        //根据总记录数创建数组
        products = new String[rowCount][9];
        sql = "select * from product where categoryId = " + categoryId;
        rs = stmt.executeQuery(sql);
        int row = 0;
        while(rs.next()){
          //将product数据表的数据放入products数组
          for(int i = 0; i < 9; i++){
            products[row][i] = rs.getString(i + 1);
          }
          row++;
        }
      }else{
        products = new String[1][1];
        products[0][0] = "没有产品数据.";
      }
      stmt.close();
    }catch(Exception ex){
      ex.printStackTrace();
    }
    //关闭数据库的联接
    closeConn(conn);
    return products;
  }
  //关闭数据库联接的方法
  public void closeConn(Connection conn){
    try{
      conn.close();
    }catch(Exception ex){
      ex.printStackTrace();
    }
  }
}