### 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;
}
}
```
- Java Web项目开发学习手册
- 一、B/S开发环境搭建
- 1.1 tomcat服务器目录结构及作用
- 1.2 在IDE开发工具上配置tomcat服务器
- 1.3 简单web项目在tomcat服务器上运行的方法
- 1.4 开发工具设置
- 1.5 总结
- 二、Servlet技术应用
- 2.1 HttpServlet中的主要方法及应用
- 2.1.1 基于Eclipse完成一个JavaWeb项目
- 2.2 HttpRequest,HttpResponse的应用
- 2.2.1客户端请求
- 2.2.2服务器响应
- 2.2.3Servlet HTTP 状态码
- 2.2.4图片验证码类
- 2.2.5注册模拟实现(带验证码)
- 2.3 ServletConfig对象和ServletContext对象的概念
- 2.4 总结
- 三、JSP技术应用
- 3.1 JSP基本语法
- 3.2 JSP标签和指令
- 3.3 JSP中的隐式对象
- 3.4 常用应用操作
- 3.4.1 JSP客户端请求
- 3.4.2 JSP服务器响应
- 3.4.3 HTTP状态码
- 3.4.4 表单处理
- 3.4.5 过滤器
- 3.4.6 Cookie处理
- 3.4.7 Session处理
- 3.4.8 文件上传
- 3.4.9 日期处理
- 3.4.10 页面重定向
- 3.4.11 点击量统计
- 3.4.12 自动刷新
- 3.4.13 发送邮件
- 3.5 JSP高级应用
- 3.5.1 JSP标准标签库(JSTL)
- 3.5.2 JSP连接数据库
- 3.5.3 JSP XML数据处理
- 3.5.4 JSP JavaBean
- 3.5.5 自定义标签
- 3.5.6 表达式语言
- 3.5.7 异常处理
- 3.5.8 调试
- 3.5.9 JSP国际化
- 3.6 实践代码
- 3.6.1 实践代码
- 3.6.2 项目实战
- 3.7 总结
- 四、MVC思想的理解和搭建MVC
- 4.1 MVC设计模式的思想
- 4.2 MVC设计模式的实现步骤
- 4.3 项目实践
- 4.4 总结
- 五、EL表达式和JSTL技术
- 5.1 EL表达式及其应用
- 5.2 常用的JSTL标签的应用
- 5.3 项目实践
- 5.4 总结
- 六、Cookie和Session
- 6.1 cookie对象的概念和应用
- 6.2 session对象的概念和应用
- 6.3 项目实践
- 6.4 总结
- 七、过滤器技术应用
- 7.1 Filter的概念及应用
- 7.2 Filter、FilterChain、FilterConfig 介绍
- 7.3 用户登录过滤案例
- 7.4 项目实战
- 7.5总结
- 八、异步请求技术
- 8.1 JSON数据格式
- 8.2 使用AJAX实现异步请求
- 8.3 用户名校验案例
- 8.4小结
- 综合项目技术实训
- 1.BS项目开发项目实战
- 2.项目需求分析和系统设计
- 2.1需求分析
- 2.2类型模型设计
- 2.3原型设计
- 3.项目数据库分析和系统设计
- 4.BS项目编程实现
- 4.1搭建框架和命名规约
- 4.2实现步骤
- 4.2.1创建实体类
- 4.2.2创建过滤器类
- 4.2.3创建工具类
- 4.2.4创建DAO接口及其实现类
- 4.2.5创建Service接口及其实现类
- 4.2.6创建测试类
- 4.2.7创建控制器类
- 5.企业开发流程规范
- 6.总结
- 九、练习题及答案
- 企业开发常用技术
- 1.Maven技术
- Java命名规范解读
- 参考资料
- 开发中常用的应用服务器和Web服务器