java二手车交易系统部分功能代码

package BuyersFunctionLayer; import MySQLConnectLayer.*; // MySQL 连接层 import buyerDemand.buyerDemand; import LoginAndRegisterFunctionLayer.LoginAndRegisterFunction; import ClassificationBasis.ClassificationBasis; import buyerDemand.buyerDemand; import Vehicle.Vehicle; import BuyerInformation.BuyerInformation; import java.security.interfaces.RSAKey; import java.sql.*; public class BuyersFunction { String buyerFlag; // 买家标示 Statement stmt; // MySQLConnectLayer 层 提供的对象 用于 SQL 查询 public BuyersFunction(String buyerFlag, Statement stmt) { this.buyerFlag = buyerFlag; // 设置 买家标示 this.stmt = stmt; } public static void main(String[] args) { // 组织层 (GUI) 调用设计步骤 // 1、买家与卖家需要 需要 先实例化 注册与登录功能层 // 2、实现登陆后、调用 getFlag() 方法 获得登录标识 // 3、使用登陆标识 实例化 功能层 对象 // 4、 使用功能时 调用功能层方法即可 MySQLConnect connect; // MYSQL 连接 LoginAndRegisterFunction larf; // 登录与注册功能 BuyersFunction buyer; // 买家功能 connect = new MySQLConnect(); // 1、创建连接对象时 建立连接 larf = new LoginAndRegisterFunction(connect.getStatement()); // 2、实例化 注册与登录 功能，需要传入 Statement 对象 // 开始登录 String id = "100000"; String passworld = "123456"; larf.login(id, passworld); // 登录 // 假如登录 成了 （需要判断 login 方法返回的标识 是否为1 ，这里省略） // 开始实例化功能 buyer = new BuyersFunction(larf.getFlag(), connect.getStatement()); // 实例化 功能，需要传入 buyerFlag 和 stmt // ------------ 现在可以 用功能了 // buyer.clsc("100002"); // System.out.println(buyer.ckptgj("100001")); // // Vehicle[] cxjg = new Vehicle[200]; // buyer.sccx(cxjg); // // buyer.cxdj("100001"); // //// buyerDemand(String mjbh, int cl, int lc, String color, int jw, String pp) // buyerDemand mjxq = new buyerDemand("null", 1, 10000, "red", 100000, "BMW"); // buyer.fbxq(mjxq); // // buyer.yykc("100001", "2018.1.10"); // // Vehicle[] clxx = new Vehicle[200]; // ClassificationBasis flyj = new ClassificationBasis(); // buyer.flcx(flyj, clxx); // // buyer.lxpt("啦啦啦啦，杰姆二手车，我亏本了。"); // // buyer.shfw("车辆过户", "100001"); BuyerInformation yhxx = new BuyerInformation(); yhxx.mjbh = larf.getFlag(); yhxx.xx = "魏雄"; yhxx.nl = 20; yhxx.dh = "100123"; yhxx.xb = "男"; buyer.szxx(yhxx); } public int ckyhxx(BuyerInformation yhxx) { // 最大 100 int flag; try { String sql = "SELECT * FROM 买家 WHERE 买家编号='" + buyerFlag + "'"; ResultSet re = stmt.executeQuery(sql); int i = 0; for (i=0; i<100 && re.next(); i++) { yhxx.mjbh = re.getString(1); yhxx.xx = re.getString(2); yhxx.nl = re.getInt(3); yhxx.dh = re.getString(4); yhxx.xb = re.getString(5); yhxx.shjg = re.getString(6); } if (i == 0) flag = 0; else flag = 1; } catch (SQLException e) { flag = -1; System.out.println("异常..."); } return flag; } public int szxx(BuyerInformation yhxx) { // 设置用户信息 int flag; // 0已为审核通过 try { String sql = "SELECT 审核状态 FROM 买家 WHERE 买家编号='" + buyerFlag + "'"; ResultSet re = stmt.executeQuery(sql); if (!re.next()) { // 无数据 sql = "INSERT INTO 买家 VALUES('" + buyerFlag + "', '" + yhxx.xx + "', " + yhxx.nl + ", '" + yhxx.dh + "', '" + yhxx.xb + "', '" + "待审核" + "')"; flag = 1; } else { if (re.getString(1) == "审核通过") flag = 0; else { sql = "UPDATE 买家 SET 姓名='" + yhxx.xx + "', 年龄=" + yhxx.nl + ", 电话='" + yhxx.dh + "', 性别='" + yhxx.xb + "' WHERE 买家编号='" + buyerFlag + "'"; flag = 1; } } stmt.executeUpdate(sql); re.close(); } catch (SQLException e) { flag = -1; e.printStackTrace(); System.out.println("异常..."); } return flag; } public int cxdj(String clbh) { // 询底价功能 int flag; // -1：异常 -2 or 0：无底价 》=1：查询价格 try { String sql = "SELECT 底价 FROM 车辆 WHERE 车辆编号='" + clbh + "'"; ResultSet re = stmt.executeQuery(sql); if (re.next()) { flag = re.getInt("底价"); System.out.println("底价：" + flag); } else { flag = -2; System.out.println("无底价..."); } } catch (SQLException e) { flag = -1; System.out.println("异常..."); } return flag; } public int flcx(ClassificationBasis flyj, Vehicle[] clxx) { // 分类查询功能 最大100条信息 int flag; try { String sql = "SELECT * FROM 车辆 WHERE 品牌 LIKE '" + flyj.pp + "' AND 颜色 LIKE '" + flyj.color + "' AND 车牌所在地 LIKE '" + flyj.cpszd + "' AND 发布价格 BETWEEN " + flyj.fbjg_ + " AND " + flyj.fbjg__ + " AND 车龄 BETWEEN " + flyj.cl_ + " AND " + flyj.cl__ + " AND 里程 BETWEEN " + flyj.lc_ + " AND " + flyj.lc__ + " ORDER BY " + flyj.pxyj + ";"; ResultSet re = stmt.executeQuery(sql); int i=0; for (i=0; i<100 && re.next(); i++) { Vehicle temp = new Vehicle(); temp.clbh = re.getString(1); temp.czbh = re.getString(2); temp.pp = re.getString(3); temp.fbjg = re.getInt(4); temp.cl = re.getInt(5); temp.lc = re.getInt(6); temp.color = re.getString(7); temp.cpszd = re.getString(8); temp.dj = re.getInt(9); temp.ptgj = re.getInt(10); temp.ptsftg = re.getBoolean(11); temp.shzt = re.getString(12); clxx[i] = temp; System.out.println(temp.clbh); } flag = i; System.out.println("分类查询成功..."); } catch (SQLException e) { e.printStackTrace(); flag = -1; System.out.println("失败..."); } return flag; } public int clsc(String clbh) { // 车辆收藏功能 int flag; // 1：成功 、0：收藏失败，重复收藏 try { String sql = "INSERT INTO 收藏 VALUES('" + buyerFlag + "', '" + clbh + "');"; stmt.executeUpdate(sql); flag = 1; System.out.println("收藏成功..."); } catch (SQLException e) { flag = 0; System.out.println("收藏失败：重复收藏..."); } return flag; } public int clxqcx(String clbh,Vehicle cxjg) { // 车辆详情查询 int flag; try { String sql = "SELECT * FROM 车辆 " + "WHERE 车辆编号='" + clbh + "';"; ResultSet re = stmt.executeQuery(sql); int i=0; for (i = 0; i<100 && re.next(); i++) { Vehicle temp = new Vehicle(); temp.clbh = re.getString(1); temp.czbh = re.getString(2); temp.pp = re.getString(3); temp.fbjg = re.getInt(4); temp.cl = re.getInt(5); temp.lc = re.getInt(6); temp.color = re.getString(7); temp.cpszd = re.getString(8); temp.dj = re.getInt(9); temp.ptgj = re.getInt(10); temp.ptsftg = re.getBoolean(11); temp.shzt = re.getString(12); System.out.println(temp.clbh); cxjg = temp; } flag = i; System.out.println("查询收藏成功..."); } catch (SQLException e) { flag = 0; System.out.println("查询失败..."); } return flag; } public int sccx(Vehicle[] cxjg) { // 收藏查询 int flag; try { String sql = "SELECT 车辆.* FROM 收藏, 车辆 " + "WHERE 收藏.买家编号='" + buyerFlag + "' AND 收藏.车辆编�