1.写好数据库连接的工具类–DBUtils。
2.写好要操作的数据库表的实体类(entity)–User。
3.写代码.
案例如下:
public class UserDao {
private Connection conn = null;
private PreparedStatement ps = null;
private ResultSet rs = null;
/**
* 1. 增加操作
* @param user
* 接收一个User对象,将对象添加到数据库表中
*/
public int addUser(User user) {
// 定义要执行的SQL语句
String sql = "INSERT INTO tb_user(userName, `password`) VALUES('"+ user.getUserName() +"', MD5('"+ user.getPassword() +"'))";
// 设置
int n = 0;
try {
//通过DBUtis类中的getConnection方法获得与数据库的连接
conn = DBUtils.getConnection();
//预编译执行上面定义的SQL语句(不是真正执行)
ps = conn.prepareStatement(sql); //预编译
//执行SQL
n = ps.executeUpdate();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} finally {
//关闭资源
DBUtils.close(conn, ps);
}
return n;
}
/**
* 2. 删除操作
* -- 根据uid删除记录
*/
public int delUserById(Integer uid) {
// 定义要执行的SQL语句
String sql = "delete from tb_user where uid=" + uid;
// 设置
int n = 0;
try {
//通过DBUtis类中的getConnection方法获得与数据库的连接
conn = DBUtils.getConnection();
//预编译执行上面定义的SQL语句(不是真正执行)
ps = conn.prepareStatement(sql); //预编译
//执行SQL
n = ps.executeUpdate();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} finally {
//关闭资源
DBUtils.close(conn, ps);
}
return n;
}
/**
* 3. 修改操作
* -- 根据uid修改密码或状态
*/
public int updateUser(User user) {
// 定义要执行的SQL语句
String sql = "update tb_user set `password`="+ user.getPassword() +", status="+ user.getStatus() +" where uid="+ user.getUid();
// 设置
int n = 0;
try {
//通过DBUtis类中的getConnection方法获得与数据库的连接
conn = DBUtils.getConnection();
//预编译执行上面定义的SQL语句(不是真正执行)
ps = conn.prepareStatement(sql); //预编译
//执行SQL
n = ps.executeUpdate();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} finally {
//关闭资源
DBUtils.close(conn, ps);
}
return n;
}
/**
* 4. 查询操作
* -- 查询表中所有记录
*/
public List<User> getAllUser(){
String sql = "select * from tb_user";
List<User> users = new ArrayList<User>();
try {
//获得连接
conn = DBUtils.getConnection();
//执行sql
ps = conn.prepareStatement(sql);
rs = ps.executeQuery(); //获得查询出来的结果集
while(rs.next()) {
int uid = rs.getInt("uid");
String userName = rs.getString("userName");
String password = rs.getString("password");
int status = rs.getInt("status");
Date regtime = rs.getDate("regtime");
//实例化一个User对象,并添加到List集合
users.add(new User(uid, userName, password, status, regtime));
}
} catch (Exception e) {
// TODO: handle exception
e.printStackTrace();
} finally {
DBUtils.close(conn, ps, rs);
}
return users;
}
// 查询1条记录
public User Se(String name) {
String sql="SELECT * FROM `tb_user` WHERE `userName`='"+name+"'";
User user=null;
try {
conn=DBUtils.getConnection();
ps=conn.prepareStatement(sql);
rs= ps.executeQuery();
while(rs.next()) {
user=new User();
user.setUid(rs.getInt("uid"));
user.setPassword(rs.getString("password"));
user.setRegtime(rs.getDate("regtime"));
user.setStatus(rs.getInt("status"));
user.setUserName(name);
}
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}finally {
DBUtils.close(conn, ps);
}
return user;
}
}
本文地址:https://blog.csdn.net/Do_LaLi/article/details/107170336