JDBC实现增删改查功能

avatar 2017年07月21日21:53:40 1 3908 views
博主分享免费Java教学视频，B站账号：Java刘哥 ，长期提供技术问题解决、项目定制：本站商品点此

一、数据库结构


1、在本地 localhost，用户名 root ,密码为空，新建数据库 jdbc_study，新建数据表 users 表

users 表结构如下



有七个字段，分别是 id,name,password,birthday,email,create_date,status


二、代码实现


总共有4个类，分别是 DBUtil.java，Users.java，UsersDAO.java，UsersAction.java

采用 MVC 思想，虽然这里没有 View，测试可以在 UsersAction.java

为了方便管理分别建了四个包（package）,具体可以看代码头部

DBUtil.java
  1. package com.liuyanzhao.db;
  3. import java.sql.Connection;
  4. import java.sql.DriverManager;
  5. import java.sql.SQLException;
  7. /*
  8.  * @author LiuYanzhao
  9.  */
  10. public class DBUtil {
  12.     private static final String URL = "jdbc:mysql://127.0.0.1:3306/jdbc_study"
  13.             + "?useUnicode=true&characterEncoding=utf8";//防止中文读取乱码
  14.     private static final String USER = "root";
  15.     private static final String PASSWORD = "";
  17.     public static Connection conn = null;
  19.     //静态代码块最先执行，先执行一次
  20.     static {
  21.         try {
  22.             //加载驱动
  23.             Class.forName("com.mysql.jdbc.Driver");
  24.             //获取连接
  25.             conn = DriverManager.getConnection(URL, USER, PASSWORD);
  26.         } catch (ClassNotFoundException e) {
  27.             e.printStackTrace();
  28.         } catch (SQLException e) {
  29.             e.printStackTrace();
  30.         }
  31.     }
  32.     //单例模式，使对象唯一性
  33.     public static Connection getConnection() {
  34.         return conn;
  35.     }
  37.     public static void main(String[] args) {
  39.     }
  40. }

Users.java
  1. package com.liuyanzhao.model;
  3. import java.sql.Date;
  5. /*
  6.  * @author LiuYanzhao
  7.  */
  8. public class Users {
  9.     private int id;
  10.     private String name;
  11.     private String password;
  12.     private Date birthday;
  13.     private String Email;
  14.     private Date create_date;
  15.     private int status;
  16.     public int getId() {
  17.         return id;
  18.     }
  19.     public void setId(int id) {
  20.         this.id = id;
  21.     }
  22.     public String getName() {
  23.         return name;
  24.     }
  25.     public void setName(String name) {
  26.         this.name = name;
  27.     }
  28.     public String getPassword() {
  29.         return password;
  30.     }
  31.     public void setPassword(String password) {
  32.         this.password = password;
  33.     }
  34.     public Date getBirthday() {
  35.         return birthday;
  36.     }
  37.     public void setBirthday(Date birthday) {
  38.         this.birthday = birthday;
  39.     }
  40.     public String getEmail() {
  41.         return Email;
  42.     }
  43.     public void setEmail(String email) {
  44.         Email = email;
  45.     }
  46.     public Date getCreate_date() {
  47.         return create_date;
  48.     }
  49.     public void setCreate_date(Date create_date) {
  50.         this.create_date = create_date;
  51.     }
  52.     public int getStatus() {
  53.         return status;
  54.     }
  55.     public void setStatus(int status) {
  56.         this.status = status;
  57.     }
  59. }

UsersDAO.java
  1. package com.liuyanzhao.dao;
  3. import java.sql.Connection;
  4. import java.sql.PreparedStatement;
  5. import java.sql.ResultSet;
  6. import java.sql.SQLException;
  7. import java.text.ParseException;
  8. import java.util.ArrayList;
  9. import java.util.List;
  11. import com.liuyanzhao.db.DBUtil;
  12. import com.liuyanzhao.model.Users;
  14. /*
  15.  * @author LiuYanzhao
  16.  */
  17. public class UsersDAO {
  19.     //添加用户
  20.     public void addUsers(Users u) throws SQLException, ParseException {
  21.         Connection conn = DBUtil.getConnection();
  22.         String sql = " insert into users "
  23.                    + "(name,password,birthday,email,create_date,status)"
  24.                    + " values("
  25.                    + "?,?,?,?,current_date(),1"
  26.                    + ") ";
  27.         PreparedStatement ptmt = conn.prepareStatement(sql);
  28.         ptmt.setString(1, u.getName());
  29.         ptmt.setString(2, u.getPassword());
  30.         ptmt.setDate(3, u.getBirthday());
  31.         ptmt.setString(4, u.getEmail());
  32.         ptmt.executeUpdate();
  33.     }
  35.     //删除用户
  36.     public void deleUser(int id) throws SQLException {
  37.         Connection conn = DBUtil.getConnection();
  38.         String sql = " delete from users where id=?";
  39.         PreparedStatement ptmt = conn.prepareStatement(sql);
  40.         ptmt.setInt(1, id);
  41.         ptmt.executeUpdate();
  42.     }
  44.     //修改用户
  45.     public void updateUser(Users u) throws SQLException {
  46.         Connection conn = DBUtil.getConnection();
  47.         String sql = " update users set "
  48.                    + " name=?,password=?,birthday=?,email=?,"
  49.                    + " status=?"
  50.                    + " where id=?";
  51.         PreparedStatement ptmt = conn.prepareStatement(sql);
  52.         ptmt.setString(1, u.getName());
  53.         ptmt.setString(2, u.getPassword());
  54.         ptmt.setDate(3, u.getBirthday());
  55.         ptmt.setString(4, u.getEmail());
  56.         ptmt.setInt(5, u.getStatus());
  57.         ptmt.setInt(6, u.getId());
  58.         ptmt.executeUpdate();
  59.     }
  61.     //根据id查询单个用户
  62.     public Users get(int id) throws SQLException {
  63.         Connection conn = DBUtil.getConnection();
  64.         String sql = " select * from users where id=?";
  65.         PreparedStatement ptmt = conn.prepareStatement(sql);
  66.         ptmt.setInt(1, id);
  67.         ResultSet rs = ptmt.executeQuery();
  68.         Users u = null;
  69.         while(rs.next()) {
  70.             u = new Users();
  71.             u.setId(rs.getInt("id"));
  72.             u.setName(rs.getString("name"));
  73.             u.setPassword(rs.getString("password"));
  74.             u.setBirthday(rs.getDate("birthday"));
  75.             u.setEmail(rs.getString("email"));
  76.             u.setCreate_date(rs.getDate("create_date"));
  77.             u.setStatus(rs.getInt("status"));
  78.         }
  79.         return u;
  80.     }
  82.     //遍历用户信息
  83.     public List<Users> query() throws SQLException {
  84.         List<Users> result = new ArrayList<Users>();
  85.         Connection conn = DBUtil.getConnection();
  86.         String sql = " select * from users";
  87.         PreparedStatement ptmt = conn.prepareStatement(sql);
  88.         ResultSet rs = ptmt.executeQuery();
  89.         Users u = null;
  90.         while(rs.next()) {
  91.             u = new Users();
  92.             u.setId(rs.getInt("id"));
  93.             u.setName(rs.getString("name"));
  94.             u.setPassword(rs.getString("password"));
  95.             u.setBirthday(rs.getDate("birthday"));
  96.             u.setEmail(rs.getString("email"));
  97.             u.setCreate_date(rs.getDate("create_date"));
  98.             u.setStatus(rs.getInt("status"));
  99.             result.add(u);
  100.         }
  101.         return result;
  102.     }
  104. }

UsersAction.java
  1. package com.liuyanzhao.action;
  3. import java.sql.Date;
  4. import java.sql.SQLException;
  5. import java.text.ParseException;
  6. import java.text.SimpleDateFormat;
  7. import java.util.List;
  9. import com.liuyanzhao.dao.UsersDAO;
  10. import com.liuyanzhao.model.Users;
  12. /*
  13.  * @author LiuYanzhao
  14.  */
  15. public class UsersAction {
  16.     //添加用户
  17.     public void add(Users u) throws SQLException, ParseException {
  18.         UsersDAO dao = new UsersDAO();
  19.         dao.addUsers(u);
  20.     }
  21.     //删除用户
  22.     public void dele(int id) throws SQLException {
  23.         UsersDAO dao = new UsersDAO();
  24.         dao.deleUser(id);
  25.     }
  26.     //修改用户
  27.     public void edit(Users u) throws SQLException {
  28.         UsersDAO dao = new UsersDAO();
  29.         dao.updateUser(u);
  30.     }
  31.     //根据id查询单条用户
  32.     public Users get(int id) throws SQLException {
  33.         UsersDAO dao = new UsersDAO();
  34.         return dao.get(id);
  35.     }
  36.     //遍历查询所有用户
  37.     public List<Users> query() throws SQLException {
  38.         UsersDAO dao = new UsersDAO();
  39.         return dao.query();
  40.     }
  42.     public static void main(String[] args) throws ParseException, SQLException {
  45.         //添加用户测试
  46.         /*Users u = new Users();
  47.         u.setName("小田");
  48.         u.setPassword("123456");
  49.         u.setBirthday(new Date((new SimpleDateFormat("yyyy-MM-dd").parse("2006-8-10")).getTime()));
  50.         u.setEmail("xiaotian@126.com");
  51.         UsersAction action = new UsersAction();
  52.         action.add(u);*/
  55.         //删除用户测试
  56.         /*UsersAction action2 = new UsersAction();
  57.         action2.dele(5);*/
  60.         //更新用户测试
  61.         /*Users u3 = new Users();
  62.         u3.setId(7);
  63.         u3.setName("小雅");
  64.         u3.setPassword("aaaaaa");
  65.         u3.setBirthday(new Date((new SimpleDateFormat("yyyy-MM-dd").parse("2014-7-21")).getTime()));
  66.         u3.setEmail("xiaoya@126.com");
  67.         u3.setStatus(1);
  68.         UsersAction action3 = new UsersAction();
  69.         action3.edit(u3); */
  72.         //查询用户测试,单条数据
  73.         /*UsersAction action4 = new UsersAction();
  74.         Users u4 = action4.get(7);
  75.         System.out.println(u4.getId());
  76.         System.out.println(u4.getName());
  77.         System.out.println(u4.getPassword());
  78.         System.out.println(u4.getBirthday());
  79.         System.out.println(u4.getEmail());
  80.         System.out.println(u4.getCreate_date());
  81.         System.out.println(u4.getStatus());*/
  83.         //查询所有用户信息，遍历
  84.         UsersAction action5 = new UsersAction();
  85.         List<Users> list = action5.query();
  86.         for(int i=0;i<list.size();i++) {
  87.             System.out.print(list.get(i).getId()+" ");
  88.             System.out.print(list.get(i).getName()+" ");
  89.             System.out.print(list.get(i).getPassword()+" ");
  90.             System.out.print(list.get(i).getBirthday()+" ");
  91.             System.out.print(list.get(i).getEmail()+" ");
  92.             System.out.print(list.get(i).getCreate_date()+" ");
  93.             System.out.print(list.get(i).getStatus()+" ");
  94.             System.out.println();
  95.         }
  96.     }
  97. }

三、知识拓展


1、JDBC常用API和使用

2、MySQL常用语句

3、execute、executeUpdate、executeQuery三者的区别

4、Java中PreparedStatement和Statement区别

5、java中ArrayList实例讲解

6、Java中如何使某个类的对象唯一性，只能创建一个对象



本文链接：https://liuyanzhao.com/5323.html

转载请务必注明

历史上的今天
七月
21日
  • 微信
  • 交流学习，资料分享
  • weinxin
  • 个人淘宝
  • 店铺名：言曌博客咨询部

  • (部分商品未及时上架淘宝)
avatar

发表评论

avatar 登录者：匿名
匿名评论，评论回复后会有邮件通知

  

已通过评论：0   待审核评论数：0