JDBC增删改查

最新推荐文章于 2022-10-29 10:05:06 发布
最新推荐文章于 2022-10-29 10:05:06 发布
阅读量688 收藏 3
点赞数
分类专栏： Java 文章标签： mysql jdbc 数据库 java sql
版权声明：本文为博主原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接和本声明。
本文链接：https://blog.csdn.net/Deep___Learning/article/details/108835407
版权

JDBC增删改查

操作步骤

1、加载驱动

2、获取连接

3、执行相应的操作（增、删、改、查）

4、释放资源

在这里插入图片描述

JDBCTest

package com.lyh;

import com.lyh.dao.UserDaoImpl;
import com.lyh.pojo.User;

import java.sql.Date;
import java.util.List;

/**
 * @author martin
 * @date 2020/9/27
 **/
public class JDBCTest {
    public static void main(String[] args) {
        UserDaoImpl dao = new UserDaoImpl();
        // 查询所有用户
        List<User> userList = dao.selectAllUser();
        for (User user : userList) {
            System.out.println(user);
        }
        System.out.println("==========");
        // 根据名字查询用户
        System.out.println(dao.selectUserByName("李四"));
        System.out.println("==========");
        // 插入用户
        User user = new User(2, "李四", "111111", "li@163.com", new Date(System.currentTimeMillis()));
        System.out.println(dao.insertUser(user));
        System.out.println("==========");
        // 删除用户
        System.out.println(dao.deleteUser(4));
        System.out.println("==========");
        // 修改用户
        System.out.println(dao.updateUser(user));
        System.out.println("==========");
        List<User> users = dao.selectAllUser();
        for (User u : users) {
            System.out.println(u);
        }
    }
}

User

package com.lyh.pojo;

import java.sql.Date;

/**
 * @author martin
 * @date 2020/9/27
 **/
public class User {
    private int id;
    private String name;
    private String password;
    private String email;
    private Date birthday;

    public User() {

    }

    public User(int id, String name, String password, String email, Date birthday) {
        this.id = id;
        this.name = name;
        this.password = password;
        this.email = email;
        this.birthday = birthday;
    }

    public int getId() {
        return id;
    }

    public void setId(int id) {
        this.id = id;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public String getPassword() {
        return password;
    }

    public void setPassword(String password) {
        this.password = password;
    }

    public String getEmail() {
        return email;
    }

    public void setEmail(String email) {
        this.email = email;
    }

    public Date getBirthday() {
        return birthday;
    }

    public void setBirthday(Date birthday) {
        this.birthday = birthday;
    }

    @Override
    public String toString() {
        return "User{" +
                "id=" + id +
                ", name='" + name + '\'' +
                ", password='" + password + '\'' +
                ", email='" + email + '\'' +
                ", birthday=" + birthday +
                '}';
    }
}

BaseDao

package com.lyh.dao;

import java.sql.*;

/**
 * @author martin
 * @date 2020/9/27
 **/
public class BaseDao {
    private final static String driver = "com.mysql.cj.jdbc.Driver";
    private final static String url = "jdbc:mysql://localhost:3306/jdbc_study?useUnicode=true&characterEncoding=utf-8&serverTimezone=UTC";
    private final static String username = "root";
    private final static String password = "root";

    public static Connection getConnection() {
        Connection connection = null;
        try {
            // 加载驱动
            Class.forName(driver);
            // 获取连接
            connection = DriverManager.getConnection(url, username, password);
        } catch (ClassNotFoundException | SQLException e) {
            e.printStackTrace();
        }
        return connection;
    }
    public static boolean closeResource(Connection connection, PreparedStatement preparedStatement, ResultSet resultSet) {
        boolean flag = true;
        if (resultSet != null) {
            try {
                resultSet.close();
            } catch (SQLException e) {
                e.printStackTrace();
                flag = false;
            }
        }
        if (preparedStatement != null) {
            try {
                preparedStatement.close();
            } catch (SQLException e) {
                e.printStackTrace();
                flag = false;
            }
        }
        if (connection != null) {
            try {
                connection.close();
            } catch (SQLException e) {
                e.printStackTrace();
                flag = false;
            }
        }
        return flag;
    }
}

UserDao

package com.lyh.dao;

import com.lyh.pojo.User;

import java.util.List;

/**
 * @author martin
 * @date 2020/9/27
 **/
public interface UserDao {
    /**
     * 增加用户
     * @param user
     * @return
     */
    int insertUser(User user);

    /**
     * 根据id删除用户
     * @param id
     * @return
     */
    int deleteUser(int id);

    /**
     * 修改用户
     * @param user
     * @return
     */
    int updateUser(User user);

    /**
     * 根据名字查询用户
     * @param name
     * @return
     */
    User selectUserByName(String name);

    /**
     * 查找所有用户
     * @return
     */
    List<User> selectAllUser();
}

UserDaoImpl

package com.lyh.dao;

import com.lyh.pojo.User;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

/**
 * @author martin
 * @date 2020/9/27
 **/
public class UserDaoImpl implements UserDao{
    @Override
    public int insertUser(User user) {
        int n = 0;
        String sql = "insert into users values (default, ?, ?, ?, ?)";
        Connection conn = null;
        PreparedStatement preparedStatement = null;
        try {
            // 获取连接
            conn = BaseDao.getConnection();
            preparedStatement = conn.prepareStatement(sql);
            preparedStatement.setString(1, user.getName());
            preparedStatement.setString(2, user.getPassword());
            preparedStatement.setString(3, user.getEmail());
            preparedStatement.setDate(4, user.getBirthday());
            n = preparedStatement.executeUpdate();
            // 释放资源
            BaseDao.closeResource(conn, preparedStatement, null);
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return n;
    }

    @Override
    public int deleteUser(int id) {
        int n = 0;
        String sql = "delete from users where id = ?";
        PreparedStatement preparedStatement = null;
        Connection conn = null;
        try {
            // 获取连接
            conn = BaseDao.getConnection();
            preparedStatement = conn.prepareStatement(sql);
            preparedStatement.setInt(1, id);
            n = preparedStatement.executeUpdate();
            // 释放资源
            BaseDao.closeResource(conn, preparedStatement, null);
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return n;
    }

    @Override
    public int updateUser(User user) {
        int n = 0;
        String sql = "update users set name = ?, password = ?, email = ?, birthday = ? where id = ?";
        Connection conn = null;
        PreparedStatement preparedStatement = null;
        try {
            // 获取连接
            conn = BaseDao.getConnection();
            preparedStatement = conn.prepareStatement(sql);
            preparedStatement.setString(1, user.getName());
            preparedStatement.setString(2, user.getPassword());
            preparedStatement.setString(3, user.getEmail());
            preparedStatement.setDate(4, user.getBirthday());
            preparedStatement.setInt(5, user.getId());
            n = preparedStatement.executeUpdate();
            // 释放资源
            BaseDao.closeResource(conn, preparedStatement, null);
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return n;
    }

    @Override
    public User selectUserByName(String name) {
        User user = null;
        String sql = "select * from users where name = ?";
        Connection conn = null;
        PreparedStatement preparedStatement = null;
        try {
            conn = BaseDao.getConnection();
            preparedStatement = conn.prepareStatement(sql);
            preparedStatement.setString(1, name);
            ResultSet resultSet = preparedStatement.executeQuery();
            if (resultSet.next()) {
                user = new User();
                user.setId(resultSet.getInt("id"));
                user.setName(resultSet.getString("name"));
                user.setPassword(resultSet.getString("password"));
                user.setEmail(resultSet.getString("email"));
                user.setBirthday(resultSet.getDate("birthday"));
            }
            // 释放资源
            BaseDao.closeResource(conn, preparedStatement, resultSet);
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return user;
    }

    @Override
    public List<User> selectAllUser() {
        List<User> userList = new ArrayList<>();
        Connection conn = null;
        PreparedStatement preparedStatement = null;
        String sql = "select * from users";
        try {
            conn = BaseDao.getConnection();
            preparedStatement = conn.prepareStatement(sql);
            ResultSet resultSet = preparedStatement.executeQuery();
            while (resultSet.next()) {
                User user = new User();
                user.setId(resultSet.getInt("id"));
                user.setName(resultSet.getString("name"));
                user.setPassword(resultSet.getString("password"));
                user.setEmail(resultSet.getString("email"));
                user.setBirthday(resultSet.getDate("birthday"));
                userList.add(user);
            }
            // 释放资源
            BaseDao.closeResource(conn, preparedStatement, resultSet);
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return userList;
    }
}

执行结果

User{id=1, name='admin', password='123456', email='1@qq.com', birthday=2020-09-29}
User{id=2, name='李四', password='111111', email='li@163.com', birthday=2020-09-27}
User{id=3, name='tom', password='tom', email='tom@qq.com', birthday=2008-01-01}
User{id=4, name='lyh', password='liuyuhe', email='104@qq.com', birthday=2020-09-07}
User{id=5, name='李四', password='111111', email='li@163.com', birthday=2020-09-27}
User{id=6, name='李四', password='111111', email='li@163.com', birthday=2020-09-27}
==========
User{id=2, name='李四', password='111111', email='li@163.com', birthday=2020-09-27}
==========
1
==========
1
==========
1
==========
User{id=1, name='admin', password='123456', email='1@qq.com', birthday=2020-09-29}
User{id=2, name='李四', password='111111', email='li@163.com', birthday=2020-09-27}
User{id=3, name='tom', password='tom', email='tom@qq.com', birthday=2008-01-01}
User{id=5, name='李四', password='111111', email='li@163.com', birthday=2020-09-27}
User{id=6, name='李四', password='111111', email='li@163.com', birthday=2020-09-27}
User{id=7, name='李四', password='111111', email='li@163.com', birthday=2020-09-27}

Process finished with exit code 0

代码

蒟蒻写博客不易，加之本人水平有限，写作仓促，错误和不足之处在所难免，谨请读者和各位大佬们批评指正。
如需转载，请署名作者并附上原文链接，蒟蒻非常感激
名称：虐猫人薛定谔
博客地址：https://liuyuhe.blog.csdn.net/

JDBC的增删改查
weixin_65492216的博客
11-01 236
一、在mysql数据库中建表二、编写程序创建mysql_conn，存放DB_Helper类，用来连接数据库创建entity包，存放Emp类，作为用户的实体类创建dao包，存放Emp_dao接口，用来定义方法创建dao_impl包，存放接口的实现类Emp_impl创test包，存放Test测试类一、添加用户：一、接口Emp_dao中定义方法二、接口实现类Emp_impl中实现接口的方法三、测试类中调用方法。
JDBC之增删改查
风清扬的博客
07-20 1121
一、什么是JDBC JDBC（Java DataBase Connectivity）就是Java数据库连接，用Java语言来操作数据库。简单地说，JDBC就是用于执行SQL语句的一系列Java API。 二、为什么要使用JDBC 早期SUN公司想编写一套可以连接天下所有数据库的API，但是因为各个厂商的数据库服务器差异太大了，这任务几乎无法实现。后来SUN开始与数据库厂商们讨论，最终
jdbc的增删改查
m0_72960906的博客
10-29 486
这里首先我们创建一个teacher表,然后创建一个Teacher类，将表中所有的列写为私有变量，并且写出所以的getset方法，构造方法，及toString方法，然后创建一个操作类里面书写怎删改查的代码，最后书写一个测试类进行运行操作类中的代码，基本操作如下代码：（其中的DB01是我的工具类）
Servlet +jsp+jdbc增删改查学生信息
01-07
【Servlet +jsp+jdbc增删改查学生信息】是一个经典的Web开发示例，它结合了Java服务器页面（JSP）、Servlet和Java数据库连接（JDBC）技术，用于创建一个简单的学生信息管理系统。这个项目适用于初学者，可以帮助他们...
JDBC增删改查和查唯一的完整代码解析
08-31
在本文中，我们将深入探讨JDBC如何实现对数据库的增删改查（CRUD）操作以及查找唯一数据的完整代码解析。 首先，我们需要一个实体类来表示数据库中的表结构。在这个例子中，我们有一个名为`Hehe`的实体类，包含三个...
jdbc.rar_JDBC增删改查_java jdbc_jdbc_jdbc 增删改查_jdbc封装
09-24
在这个“jdbc.rar”压缩包中，我们很显然会看到关于使用Java JDBC进行数据操作的示例代码，特别是增删改查（CRUD）功能的实现以及可能的封装。 首先，让我们理解JDBC的基本工作流程： 1. **加载驱动**：在使用JDBC...
jabc.rar_JDBC增删改查_java jdbc
09-15
总结来说，"jabc.rar_JDBC增删改查_java jdbc"的示例旨在教育开发者如何使用Java的JDBC API与数据库进行交互，涵盖基本的数据库操作，这对于任何Java开发者理解和构建数据驱动的应用都是至关重要的技能。通过实践...
jdbc.rar_JDBC增删改查_inq6z_java_jdbc
09-25
**三、JDBC增删改查操作** 1. **增加（Insert）**：使用PreparedStatement的setXXX()方法设置参数，然后调用executeUpdate()插入数据。 2. **删除（Delete）**：根据条件构造SQL删除语句，执行executeUpdate()。 ...
jdbc增删改查
qiuyujiaoqiuyulong的专栏
04-22 881
1.从学生表中查询所有信息，并在控制台显示。 import java.sql.*; public class Query1 { public static void main(String[] args) { //指定驱动，得到数据库连接 try{ String DBURL = "jdbc:sqlserver://localhost:1433;DataBaseName=student"
评论
添加红包

请填写红包祝福语或标题

个

红包个数最小为10个

元

红包金额最低5元

当前余额3.43元 前往充值 >
需支付：10.00元
成就一亿技术人!
领取后你会自动成为博主和红包主的粉丝 规则
hope_wisdom
发出的红包
实付元
使用余额支付
点击重新获取
扫码支付
钱包余额 0

抵扣说明：

1.余额是钱包充值的虚拟货币，按照1:1的比例进行支付金额的抵扣。
2.余额无法直接购买下载，可以购买VIP、付费专栏及课程。

余额充值