ThinkChat2.0新版上线,更智能更精彩,支持会话、画图、阅读、搜索等,送10W Token,即刻开启你的AI之旅 广告
### 1.用户数据处理接口及实现类 ``` package com.baishenghua200.dao; import java.util.List; import java.util.Map; import com.baishenghua200.pojo.User200; /** * IUserDao200.java(用户数据处理接口) * * @desc 主要定义一些方法:查询所有、条件查询、序号查询以及添加、修改和删除等方法。 * @author 柏圣华 * @date 2022-1-3 * */ public interface IUserDao200 { public List<User200> findAll200();// 查询所有 User200 findUserByUsernameAndPassword(String username, String password);//用户登录验证 void add200(User200 user200);//添加方法 void delete200(int id);//删除方法 User200 findById200(int i);//根据序号查询方法 void update200(User200 user200);//更新方法 /** * 查询总记录数 * * @return * @param condition */ int findTotalCount(Map<String, String[]> condition); /** * 分页查询每页记录 * * @param start * @param rows * @param condition * @return */ List<User200> findByPage(int start, int rows, Map<String, String[]> condition); } ``` ``` package com.baishenghua200.dao.impl; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.util.ArrayList; import java.util.List; import java.util.Map; import com.baishenghua200.dao.IUserDao200; import com.baishenghua200.pojo.Menu200; import com.baishenghua200.pojo.User200; import com.baishenghua200.utils.DBConnection200; /** * UserDaoImpl200.java(用户数据处理具体实现类) * @desc 主要实现接口里面的增删改查的方法(查询所有、条件查询、根据序号查询以及添加、修改和删除)。 * @author 柏圣华 * @date 2021-11-26 * */ public class UserDaoImpl200 implements IUserDao200 { @Override public List<User200> findAll200() {// 查询所有信息的方法 List<User200> uList = new ArrayList<User200>();// 创建集合对象 Connection con = DBConnection200.getConn200();// 获取数据库连接 PreparedStatement pstmt = null;// 声明一个预处理变量 ResultSet rs = null;// 声明一个结果集变量 String sql = "select * from user";// 查询所有信息的sql语句 try { pstmt = con.prepareStatement(sql);// 给预处理变量赋值,同时把sql语句传入预处理对象进行处理 rs = pstmt.executeQuery();// 执行查询操作,并且把查询出来的所有结果保存到结果集rs里面 while (rs.next()) {// 从结果集rs里面进行遍历(迭代)出数据, // 从结果集中获取数据,然后构造一个菜单对象 User200 menu = new User200(rs.getInt(1), rs.getString(2), rs.getString(3), rs.getInt(4), rs.getString(5),rs.getString(6),rs.getString(7),rs.getString(8),rs.getString(9)); System.out.println(menu.toString());// 打印输出遍历的对象 uList.add(menu);// 将对象加入到集合对象uList } } catch (SQLException e) { e.printStackTrace(); } finally { DBConnection200.close(con, null, pstmt, rs); } return uList; } @Override public User200 findUserByUsernameAndPassword(String username, String password) {//根据账号和密码进行查询的方法 User200 u = null; Connection con = DBConnection200.getConn200(); PreparedStatement pstmt = null; ResultSet rs = null; String sql = "select * from user where username = ? and password = ?"; try { pstmt = con.prepareStatement(sql); pstmt.setString(1, username); pstmt.setString(2, password); rs = pstmt.executeQuery();// 执行查询方法 while (rs.next()) { u = new User200(rs.getInt(1), rs.getString(2), rs.getString(3), rs.getInt(4), rs.getString(5), rs.getString(6), rs.getString(7), rs.getString(8), rs.getString(9)); System.out.println(u); } } catch (SQLException e) { e.printStackTrace(); } finally { DBConnection200.close(con, null, pstmt, rs); } return u; } @Override public void add200(User200 user) {//添加方法 Connection con = DBConnection200.getConn200(); PreparedStatement pstmt = null; String sql = "insert into user values(null,?,?,?,?,?,?,null,null)"; try { pstmt = con.prepareStatement(sql); pstmt.setString(1, user.getName200()); pstmt.setString(2, user.getGender200()); pstmt.setInt(3, user.getAge200()); pstmt.setString(4, user.getAddress200()); pstmt.setString(5, user.getQq200()); pstmt.setString(6, user.getEmail200()); pstmt.executeUpdate();// 执行添加操作 } catch (SQLException e) { e.printStackTrace(); } finally { DBConnection200.close(con, null, pstmt, null); } } @Override public void delete200(int id) {//删除方法 Connection con = DBConnection200.getConn200(); PreparedStatement pstmt = null; String sql = "delete from user where id = ?"; try { pstmt = con.prepareStatement(sql); pstmt.setInt(1, id); pstmt.executeUpdate();// 执行删除操作 } catch (SQLException e) { e.printStackTrace(); } finally { DBConnection200.close(con, null, pstmt, null); } } @Override public User200 findById200(int id) { // 根据id进行查询的方法 User200 u = null; Connection con = DBConnection200.getConn200(); PreparedStatement pstmt = null; ResultSet rs = null; String sql = "select * from user where id = ?"; try { pstmt = con.prepareStatement(sql); pstmt.setInt(1, id); rs = pstmt.executeQuery();// 执行查询方法 while (rs.next()) { u = new User200(rs.getInt(1), rs.getString(2), rs.getString(3), rs.getInt(4), rs.getString(5), rs.getString(6), rs.getString(7), rs.getString(8), rs.getString(9)); System.out.println(u); } } catch (SQLException e) { e.printStackTrace(); } finally { DBConnection200.close(con, null, pstmt, rs); } return u; } @Override public void update200(User200 user) { Connection con = DBConnection200.getConn200(); PreparedStatement pstmt = null; String sql = "update user set name = ?,gender = ? ,age = ? , address = ? , qq = ?, email = ? where id = ?"; try { pstmt = con.prepareStatement(sql); pstmt.setString(1, user.getName200()); pstmt.setString(2, user.getGender200()); pstmt.setInt(3, user.getAge200()); pstmt.setString(4, user.getAddress200()); pstmt.setString(5, user.getQq200()); pstmt.setString(6, user.getEmail200()); pstmt.setInt(7, user.getId200()); System.out.println("update-user-"+user); int flag = pstmt.executeUpdate();// 执行更新操作 System.out.println("update-user-flag"+flag); } catch (SQLException e) { e.printStackTrace(); } finally { DBConnection200.close(con, null, pstmt, null); } } @Override public int findTotalCount(Map<String, String[]> condition) { return 0;//先不实现 } @Override public List<User200> findByPage(int start, int rows, Map<String, String[]> condition) { return null;//先不实现 } } ``` ### 2.菜单数据处理接口及实现类 ``` package com.baishenghua200.dao; import java.util.List; import com.baishenghua200.pojo.Menu200; /** * IMenuDao200.java(导航菜单数据处理接口) * @desc 主要定义一些方法:查询所有导航菜单、条件查询菜单、根据序号查询导航菜单以及添加、修改和删除菜单。 * @author 柏圣华 * @date 2022-1-3 * */ public interface IMenuDao200 { public List<Menu200> queryAll200();//查询所有导航菜单 public List<Menu200> queryByCond200(String condition200);//条件查询导航菜单 public Menu200 query200(Menu200 menu200);//根据序号查询导航菜单 public int add200(Menu200 menu200);//添加导航菜单 public int update200(Menu200 menu200);//修改导航菜单 public int delete200(Menu200 menu200);//删除导航菜单 } ``` ``` package com.baishenghua200.dao.impl; import java.util.ArrayList; import java.util.List; import java.sql.*; import com.baishenghua200.dao.IMenuDao200; import com.baishenghua200.pojo.Menu200; import com.baishenghua200.utils.DBConnection200; /** * MenuDaoImpl200.java(导航菜单数据处理具体实现类) * @desc 主要实现接口里面的增删改查的方法(查询所有导航菜单、条件查询菜单、根据序号查询菜单以及添加、修改和删除菜单)。 * @author 柏圣华 * @date 2022-1-3 * */ public class MenuDaoImpl200 implements IMenuDao200 { @Override public List<Menu200> queryAll200() {//查询所有导航菜单信息的方法 List<Menu200> menusList = new ArrayList<Menu200>();//创建导航菜单的集合对象 Connection con = DBConnection200.getConn200();//获取数据库连接 PreparedStatement pstmt = null;//声明一个预处理变量 ResultSet rs = null;//声明一个结果集变量 String sql = "select id,menuName,menuURl,menuNo from t_menu";//查询所有菜单信息的sql语句 try { pstmt = con.prepareStatement(sql);//给预处理变量赋值,同时把sql语句传入预处理对象进行处理 rs = pstmt.executeQuery();//执行查询操作,并且把查询出来的所有结果保存到结果集rs里面 while (rs.next()) {//从结果集rs里面进行遍历(迭代)出数据, //从结果集中获取数据,然后构造一个菜单对象 Menu200 menu = new Menu200(rs.getInt(1), rs.getString(2), rs.getString(3),rs.getString(4)); System.out.println(menu.toString());//打印输出遍历的菜单menu对象 menusList.add(menu);//将菜单menu对象加入到菜单的集合对象mensList } } catch (SQLException e) { e.printStackTrace(); } finally { DBConnection200.close(con, null, pstmt, rs); } return menusList; } /** * 2.根据条件查询菜单信息 * @param condition200 (导航菜单的名称menuName) * @return 满足条件的导航菜单集合menusList */ @Override public List<Menu200> queryByCond200(String condition200) { List<Menu200> menusList = new ArrayList<Menu200>(); Connection con = DBConnection200.getConn200(); PreparedStatement pstmt = null; ResultSet rs = null; //采用的是模糊查询like String sql = "select id,menuName,menuURl,menuNo from t_menu where menuName like ?"; try { pstmt = con.prepareStatement(sql); //条件condition200就是导航菜单的名称,获取菜单的名称关键字,传给sql pstmt.setString(1, "%"+condition200+"%"); rs = pstmt.executeQuery();//执行查询方法 while (rs.next()) { Menu200 menu = new Menu200(rs.getInt(1), rs.getString(2), rs.getString(3),rs.getString(4)); System.out.println(menu.toString()); menusList.add(menu); } } catch (SQLException e) { e.printStackTrace(); } finally { DBConnection200.close(con, null, pstmt, rs); } return menusList; } /** * 3.精确查询导航菜单信息的方法(根据id查询) * @param menu200(传入参数,传入一个菜单,菜单的id属性要有值) * @return 返回从数据库表中查询出来的菜单信息menu */ @Override public Menu200 query200(Menu200 menu200) { Menu200 menu = null; Connection con = DBConnection200.getConn200(); PreparedStatement pstmt = null; ResultSet rs = null; String sql = "select id,menuName,menuURl,menuNo from t_menu where id = ?";//根据id查询 try { pstmt = con.prepareStatement(sql); pstmt.setInt(1, menu200.getId200());// 调用menu200的getId200()方法,获取菜单的编号,传给sql rs = pstmt.executeQuery();// 执行查询方法 while (rs.next()) { menu = new Menu200(rs.getInt(1), rs.getString(2), rs.getString(3),rs.getString(4)); System.out.println(menu); } } catch (SQLException e) { e.printStackTrace(); } finally { DBConnection200.close(con, null, pstmt, rs); } return menu; } /** * 4.添加导航菜单信息的方法 * @param menu200(传入参数,传入一个菜单对象) * @return flag代表执行操作结果,0代表执行失败,1代表执行成功。 */ @Override public int add200(Menu200 menu200) { Connection con = DBConnection200.getConn200(); PreparedStatement pstmt = null; String sql = "INSERT INTO t_menu (menuName,menuURl,menuNo) VALUES (?,?,?)"; int flag = 0;//flag代表执行操作结果,0代表执行失败,1代表执行成功。 try { pstmt = con.prepareStatement(sql); pstmt.setString(1, menu200.getMenuName200()); pstmt.setString(2, menu200.getMenuURL200()); pstmt.setString(3, menu200.getMenuNo200()); flag = pstmt.executeUpdate();// 执行添加操作 } catch (SQLException e) { e.printStackTrace(); } finally { DBConnection200.close(con, null, pstmt, null); } return flag; } /** * 5.更新导航菜单信息的方法 * @param menu200(传入参数,传入一个菜单对象) * @return flag代表执行操作结果,0代表执行失败,1代表执行成功。 */ @Override public int update200(Menu200 menu200) { Connection con = DBConnection200.getConn200(); PreparedStatement pstmt = null; String sql = "UPDATE t_menu SET menuName = ?, menuURl = ?, menuNo = ? where id= ?"; int flag = 0;//flag代表执行操作结果,0代表执行失败,1代表执行成功。 try { pstmt = con.prepareStatement(sql); pstmt.setString(1, menu200.getMenuName200()); pstmt.setString(2, menu200.getMenuURL200()); pstmt.setString(3, menu200.getMenuNo200()); pstmt.setInt(4, menu200.getId200()); flag = pstmt.executeUpdate();// 执行更新操作 } catch (SQLException e) { e.printStackTrace(); } finally { DBConnection200.close(con, null, pstmt, null); } return flag; } /** * 6.删除导航菜单信息的方法 * @param menu200(传入参数,传入一个菜单对象) * @return flag代表执行操作结果,0代表执行失败,1代表执行成功。 */ @Override public int delete200(Menu200 menu200) { int i = 0; Connection con = DBConnection200.getConn200(); PreparedStatement pstmt = null; String sql = "DELETE FROM t_menu WHERE id = ?"; try { pstmt = con.prepareStatement(sql); pstmt.setInt(1, menu200.getId200()); i = pstmt.executeUpdate();// 执行删除操作 } catch (SQLException e) { e.printStackTrace(); } finally { DBConnection200.close(con, null, pstmt, null); } return i; } } ``` ### 3.企业数据处理接口及实现类 ``` package com.baishenghua200.dao; import java.util.List; import com.baishenghua200.pojo.CompanyInfomation200; /** * ICompanyInfomationDao200.java(公司信息数据处理接口) * @desc 主要定义一些方法:查询所有公司信息、条件查询公司信息、序号查询以及添加、修改和删除公司信息。 * @author 柏圣华 * @date 2022-1-3 * */ public interface ICompanyInfomationDao200 { public List<CompanyInfomation200> queryAll200();//查询所有公司信息 public List<CompanyInfomation200> queryByCond200(String condition200);//条件查询公司信息 public CompanyInfomation200 query200(CompanyInfomation200 ci200);//根据序号查询公司信息 public int add200(CompanyInfomation200 ci200);//添加公司信息 public int update200(CompanyInfomation200 ci200);//修改公司信息 public int delete200(CompanyInfomation200 ci200);//删除公司信息 } ``` ``` package com.baishenghua200.dao.impl; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.util.ArrayList; import java.util.List; import com.baishenghua200.dao.ICompanyInfomationDao200; import com.baishenghua200.pojo.CompanyInfomation200; import com.baishenghua200.utils.DBConnection200; /** * CompanyInfomationDaoImpl200.java(公司信息数据处理具体实现类) * @desc 主要实现接口里面的增删改查的方法(查询所有公司信息、条件查询、根据序号查询以及添加、修改和删除菜单)。 * @author 柏圣华 * @date 2022-1-3 * */ public class CompanyInfomationDaoImpl200 implements ICompanyInfomationDao200 { /** * 1.添加公司信息的方法 * @param ci200(传入参数,传入一个公司信息对象) * @return flag代表执行操作结果,0代表执行失败,1代表执行成功。 */ @Override public int add200(CompanyInfomation200 ci200) { Connection con = DBConnection200.getConn200(); PreparedStatement pstmt = null; String sql = "INSERT INTO t_companyinfo200 (ciTitle200,ciImage200,ciContent200,ciEditDate200,ciNo200) VALUES (?,?,?,?,?)"; int flag = 0;//flag代表执行操作结果,0代表执行失败,1代表执行成功。 try { pstmt = con.prepareStatement(sql); pstmt.setString(1, ci200.getCiTitle200()); pstmt.setString(2, ci200.getCiImage200()); pstmt.setString(3, ci200.getCiContent200()); pstmt.setString(4, ci200.getCiEditDate200()); pstmt.setInt(5, ci200.getCiNo200()); flag = pstmt.executeUpdate();// 执行添加操作 } catch (SQLException e) { e.printStackTrace(); } finally { DBConnection200.close(con, null, pstmt, null); } return flag; } /** * 2.查询所有公司信息的方法 * @return ciList代表执行查询后,获得的所有操作结果的集合 */ @Override public List<CompanyInfomation200> queryAll200() { // 查询所有信息的方法 List<CompanyInfomation200> ciList = new ArrayList<CompanyInfomation200>();// 创建集合对象 Connection con = DBConnection200.getConn200();// 获取数据库连接 PreparedStatement pstmt = null;// 声明一个预处理变量 ResultSet rs = null;// 声明一个结果集变量 String sql = "select ciId200,ciTitle200,ciImage200,ciContent200,ciEditDate200,ciNo200 from t_companyinfo200";// 查询所有的sql语句 try { pstmt = con.prepareStatement(sql);// 给预处理变量赋值,同时把sql语句传入预处理对象进行处理 rs = pstmt.executeQuery();// 执行查询操作,并且把查询出来的所有结果保存到结果集rs里面 while (rs.next()) {// 从结果集rs里面进行遍历(迭代)出数据, // 从结果集中获取数据,然后构造一个菜单对象 CompanyInfomation200 ci200 = new CompanyInfomation200(rs.getInt(1), rs.getString(2), rs.getString(3), rs.getString(4), rs.getString(5), rs.getInt(6)); System.out.println(ci200);// 打印输出遍历 ciList.add(ci200); } } catch (SQLException e) { e.printStackTrace(); } finally { DBConnection200.close(con, null, pstmt, rs); } return ciList; } /** * 3.根据标题进行模糊查询公司信息的方法 * @param condition200(传入参数,传入一个公司信息的标题) * @return ciList代表执行模糊查询后,获得的所有操作结果的集合 */ @Override public List<CompanyInfomation200> queryByCond200(String condition200) { // 查询满足条件的所有信息的方法 List<CompanyInfomation200> ciList = new ArrayList<CompanyInfomation200>();// 创建集合对象 Connection con = DBConnection200.getConn200();// 获取数据库连接 PreparedStatement pstmt = null;// 声明一个预处理变量 ResultSet rs = null;// 声明一个结果集变量 String sql = "select ciId200,ciTitle200,ciImage200,ciContent200,ciEditDate200,ciNo200 from t_companyinfo200 where ciTitle200 like ?";// 查询所有的sql语句 try { pstmt = con.prepareStatement(sql);// 给预处理变量赋值,同时把sql语句传入预处理对象进行处理 pstmt.setString(1, "%"+condition200+"%"); rs = pstmt.executeQuery();// 执行查询操作,并且把查询出来的所有结果保存到结果集rs里面 while (rs.next()) {// 从结果集rs里面进行遍历(迭代)出数据, // 从结果集中获取数据,然后构造一个菜单对象 CompanyInfomation200 ci200 = new CompanyInfomation200(rs.getInt(1), rs.getString(2), rs.getString(3), rs.getString(4), rs.getString(5), rs.getInt(6)); System.out.println(ci200);// 打印输出遍历 ciList.add(ci200); } } catch (SQLException e) { e.printStackTrace(); } finally { DBConnection200.close(con, null, pstmt, rs); } return ciList; } /** * 4.根据编号进行精准查询公司信息的方法 * @param ci200(传入参数,传入一个公司信息) * @return cif200代表执行精准查询后,获得的公司信息对象 */ @Override public CompanyInfomation200 query200(CompanyInfomation200 ci200) { // 查询所有信息的方法 CompanyInfomation200 cif200 = null; Connection con = DBConnection200.getConn200();// 获取数据库连接 PreparedStatement pstmt = null;// 声明一个预处理变量 ResultSet rs = null;// 声明一个结果集变量 String sql = "select ciId200,ciTitle200,ciImage200,ciContent200,ciEditDate200,ciNo200 from t_companyinfo200 where ciId200 = ?";// 查询所有的sql语句 try { pstmt = con.prepareStatement(sql);// 给预处理变量赋值,同时把sql语句传入预处理对象进行处理 pstmt.setInt(1, ci200.getCiId200()); rs = pstmt.executeQuery();// 执行查询操作,并且把查询出来的所有结果保存到结果集rs里面 while (rs.next()) {// 从结果集rs里面进行遍历(迭代)出数据, // 从结果集中获取数据,然后构造一个菜单对象 cif200 = new CompanyInfomation200(rs.getInt(1), rs.getString(2), rs.getString(3), rs.getString(4), rs.getString(5), rs.getInt(6)); System.out.println("ci200="+cif200);// 打印输出遍历 } } catch (SQLException e) { e.printStackTrace(); } finally { DBConnection200.close(con, null, pstmt, rs); } return cif200; } /** * 5.根据编号更新公司信息的方法 * @param ci200(传入参数,传入一个公司信息) * @return flag代表执行更新操作结果,0代表执行失败,1代表执行成功。 */ @Override public int update200(CompanyInfomation200 ci200) { Connection con = DBConnection200.getConn200(); PreparedStatement pstmt = null; String sql = "UPDATE t_companyinfo200 SET ciTitle200 = ?, ciImage200 = ?, ciContent200 = ? ,ciEditDate200 = ?,ciNo200=? where ciId200= ?"; int flag = 0;//flag代表执行操作结果,0代表执行失败,1代表执行成功。 try { pstmt = con.prepareStatement(sql); pstmt.setString(1, ci200.getCiTitle200()); pstmt.setString(2, ci200.getCiImage200()); pstmt.setString(3, ci200.getCiContent200()); pstmt.setString(4, ci200.getCiEditDate200()); pstmt.setInt(5,ci200.getCiNo200()); pstmt.setInt(6,ci200.getCiId200()); flag = pstmt.executeUpdate();// 执行更新操作 } catch (SQLException e) { e.printStackTrace(); } finally { DBConnection200.close(con, null, pstmt, null); } return flag; } /** * 6.根据编号删除公司信息的方法 * @param ci200(传入参数,传入一个公司信息) * @return flag代表执行删除操作结果,0代表执行失败,1代表执行成功。 */ @Override public int delete200(CompanyInfomation200 ci200) { int i = 0; Connection con = DBConnection200.getConn200(); PreparedStatement pstmt = null; String sql = "DELETE FROM t_companyinfo200 WHERE ciId200 = ?"; try { pstmt = con.prepareStatement(sql); pstmt.setInt(1, ci200.getCiId200()); i = pstmt.executeUpdate();// 执行删除操作 } catch (SQLException e) { e.printStackTrace(); } finally { DBConnection200.close(con, null, pstmt, null); } return i; } } ``` ### 4.留言数据处理接口及实现类 ``` package com.baishenghua200.dao; import java.util.List; import com.baishenghua200.pojo.Message200; /** * IMessageDao200.java(留言数据处理接口) * @desc 主要定义一些方法:查询所有留言、条件查询留言、根据序号查询留言以及添加、修改和删除留言。 * @author 柏圣华 * @date 2022-1-3 * */ public interface IMessageDao200 { public List<Message200> queryAll200();//查询所有留言 public List<Message200> queryByCond200(String condition200);//条件查询留言 public Message200 query200(Message200 message200);//根据序号查询留言 public int add200(Message200 message200);//添加留言 public int update200(Message200 message200);//修改留言 public int delete200(Message200 message200);//删除留言 } ``` ``` package com.baishenghua200.dao.impl; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.util.ArrayList; import java.util.List; import com.baishenghua200.dao.IMessageDao200; import com.baishenghua200.pojo.Menu200; import com.baishenghua200.pojo.Message200; import com.baishenghua200.utils.DBConnection200; /** * MessageDaoImpl200.java(留言数据处理具体实现类) * @desc 主要实现接口里面的增删改查的方法(查询所有留言、条件查询留言、根据序号查询留言以及添加、修改和删除留言)。 * @author 柏圣华 * @date 2022-1-3 * */ public class MessageDaoImpl200 implements IMessageDao200 { @Override public List<Message200> queryAll200() { List<Message200> msgList = new ArrayList<Message200>();//创建导航菜单的集合对象 Connection con = DBConnection200.getConn200();//获取数据库连接 PreparedStatement pstmt = null;//声明一个预处理变量 ResultSet rs = null;//声明一个结果集变量 String sql = "select id,title,content from t_message";//查询所有菜单信息的sql语句 try { pstmt = con.prepareStatement(sql);//给预处理变量赋值,同时把sql语句传入预处理对象进行处理 rs = pstmt.executeQuery();//执行查询操作,并且把查询出来的所有结果保存到结果集rs里面 while (rs.next()) {//从结果集rs里面进行遍历(迭代)出数据, //从结果集中获取数据,然后构造一个菜单对象 Message200 message200 = new Message200(rs.getInt(1), rs.getString(2), rs.getString(3)); System.out.println(message200.toString());//打印输出遍历的菜单menu对象 msgList.add(message200);//将菜单menu对象加入到菜单的集合对象mensList } } catch (SQLException e) { e.printStackTrace(); } finally { DBConnection200.close(con, null, pstmt, rs); } return msgList; } @Override public List<Message200> queryByCond200(String condition200) { List<Message200> msgList = new ArrayList<Message200>(); Connection con = DBConnection200.getConn200(); PreparedStatement pstmt = null; ResultSet rs = null; //采用的是模糊查询like String sql = "select id,title,content from t_message where title like ?"; try { pstmt = con.prepareStatement(sql); //条件condition200就是导航菜单的名称,获取菜单的名称关键字,传给sql pstmt.setString(1, "%"+condition200+"%"); rs = pstmt.executeQuery();//执行查询方法 while (rs.next()) { Message200 msg = new Message200(rs.getInt(1), rs.getString(2), rs.getString(3)); System.out.println(msg.toString()); msgList.add(msg); } } catch (SQLException e) { e.printStackTrace(); } finally { DBConnection200.close(con, null, pstmt, rs); } return msgList; } @Override public Message200 query200(Message200 message200) { Message200 msg200 = null; Connection con = DBConnection200.getConn200(); PreparedStatement pstmt = null; ResultSet rs = null; String sql = "select id,title,content from t_message where id = ?";//根据id查询 try { pstmt = con.prepareStatement(sql); pstmt.setInt(1, message200.getId200());// 调用menu200的getId200()方法,获取菜单的编号,传给sql rs = pstmt.executeQuery();// 执行查询方法 while (rs.next()) { msg200 = new Message200(rs.getInt(1), rs.getString(2), rs.getString(3)); System.out.println(msg200); } } catch (SQLException e) { e.printStackTrace(); } finally { DBConnection200.close(con, null, pstmt, rs); } return msg200; } @Override public int add200(Message200 message200) { Connection con = DBConnection200.getConn200(); PreparedStatement pstmt = null; String sql = "INSERT INTO t_message (title,content) VALUES (?,?)"; int flag = 0;//flag代表执行操作结果,0代表执行失败,1代表执行成功。 try { pstmt = con.prepareStatement(sql); pstmt.setString(1, message200.getTitle200()); pstmt.setString(2, message200.getContent200()); flag = pstmt.executeUpdate();// 执行添加操作 } catch (SQLException e) { e.printStackTrace(); } finally { DBConnection200.close(con, null, pstmt, null); } return flag; } @Override public int update200(Message200 message200) { Connection con = DBConnection200.getConn200(); PreparedStatement pstmt = null; String sql = "UPDATE t_message SET title = ?, content = ? where id= ?"; int flag = 0;//flag代表执行操作结果,0代表执行失败,1代表执行成功。 try { pstmt = con.prepareStatement(sql); pstmt.setString(1, message200.getTitle200()); pstmt.setString(2, message200.getContent200()); pstmt.setInt(3, message200.getId200()); flag = pstmt.executeUpdate();// 执行更新操作 } catch (SQLException e) { e.printStackTrace(); } finally { DBConnection200.close(con, null, pstmt, null); } return flag; } @Override public int delete200(Message200 message200) { int i = 0; Connection con = DBConnection200.getConn200(); PreparedStatement pstmt = null; String sql = "DELETE FROM t_message WHERE id = ?"; try { pstmt = con.prepareStatement(sql); pstmt.setInt(1, message200.getId200()); i = pstmt.executeUpdate();// 执行删除操作 } catch (SQLException e) { e.printStackTrace(); } finally { DBConnection200.close(con, null, pstmt, null); } return i; } } ```