Java如何对MySQL进行增删改查操作?(初学者)

2022-08-09,,,,

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

《Java如何对MySQL进行增删改查操作?(初学者).doc》

下载本文的Word格式文档,以方便收藏与打印。