### 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服務器