2024考古之还在用原始JDBC开发手搓案例实现一个模块的增删改-阿里云开发者社区

JDBC案例

将来如果完成的话

就代表对JDBC里面的知识点全部融会贯通了

其实就是对数据的增删改查

我们入门做不出来前端的内容

很正常

准备环境

建表

use mybatis;
 
create table tbl_brand
(
    id int primary key auto_increment,
 
    brand_name varchar(20),
 
    company_name varchar(20),
 
    ordered int ,
 
    description varchar(100),
 
    staus int
 
);
 
insert into tbl_brand(brand_name, company_name, ordered, description, staus)
values ('三只松鼠','三只松鼠股份有限公司',5,'好吃不上火',0),
       ('华为','华为技术有限公司',100,'华为致力于把数字世界带给每个人','1'),
       ('小米','小米科技有限公司',50,'are you ok',1);
 
SELECT * from tbl_brand;

创建实体类

封装实体类

package pojo;
 
public class Brand {
    private Integer id;
    private String brandName;
    private String companyName;
    private String ordered;
    private String description;
    private String status;
 
    public Brand() {
    }
 
    public Brand(Integer id, String brandName, String companyName, String ordered, String description, String status) {
        this.id = id;
        this.brandName = brandName;
        this.companyName = companyName;
        this.ordered = ordered;
        this.description = description;
        this.status = status;
    }
 
    /**
     * 获取
     * @return id
     */
    public Integer getId() {
        return id;
    }
 
    /**
     * 设置
     * @param id
     */
    public void setId(Integer id) {
        this.id = id;
    }
 
    /**
     * 获取
     * @return brandName
     */
    public String getBrandName() {
        return brandName;
    }
 
    /**
     * 设置
     * @param brandName
     */
    public void setBrandName(String brandName) {
        this.brandName = brandName;
    }
 
    /**
     * 获取
     * @return companyName
     */
    public String getCompanyName() {
        return companyName;
    }
 
    /**
     * 设置
     * @param companyName
     */
    public void setCompanyName(String companyName) {
        this.companyName = companyName;
    }
 
    /**
     * 获取
     * @return ordered
     */
    public String getOrdered() {
        return ordered;
    }
 
    /**
     * 设置
     * @param ordered
     */
    public void setOrdered(String ordered) {
        this.ordered = ordered;
    }
 
    /**
     * 获取
     * @return description
     */
    public String getDescription() {
        return description;
    }
 
    /**
     * 设置
     * @param description
     */
    public void setDescription(String description) {
        this.description = description;
    }
 
    /**
     * 获取
     * @return status
     */
    public String getStatus() {
        return status;
    }
 
    /**
     * 设置
     * @param status
     */
    public void setStatus(String status) {
        this.status = status;
    }
 
    public String toString() {
        return "Brand{id = " + id + ", brandName = " + brandName + ", companyName = " + companyName + ", ordered = " + ordered + ", description = " + description + ", status = " + status + "}";
    }
}

在实体类当中

基本数据类型建议使用对应的包装类

写测试用例

我们的测试类是放在example包下的

我们要做的是查询添加修改删除这四个功能

我们在之前学习到的

我们的JDBC写代码都是7步

我们首先得写一个配置类

目的是获取数据库的连接

package config;
 
import com.alibaba.druid.pool.DruidDataSourceFactory;
 
import javax.sql.DataSource;
import java.io.FileInputStream;
import java.sql.Connection;
import java.util.Properties;
 
public class GetConnection {
    public static Connection getConnection() throws Exception {
 
        //加载配置文件
        Properties prop=new Properties();
        prop.load(new FileInputStream("JDBC/druid.properties"));
 
        //获取连接池对象
        DataSource dataSource=DruidDataSourceFactory.createDataSource(prop);
 
        //获取数据库连接 Connection
        Connection connection=dataSource.getConnection();
 
        return connection;
 
    }
}

但是由于路径的缘故

我们把他写在测试里面

我们首先思考如何书写SQL;语句

然后获取连接

然后执行就行了

package example;
 
import com.alibaba.druid.pool.DruidDataSourceFactory;
 
import org.junit.Test;
import pojo.Brand;
 
import javax.sql.DataSource;
import java.io.FileInputStream;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.ArrayList;
import java.util.List;
import java.util.Properties;
 
//品牌数据的增删改查
public class BrandTest {
 
    @Test
    public void testSelectAll() throws Exception {
 
        System.out.println(System.getProperty("user.dir"));
 
        //获取连接
        Properties prop=new Properties();
        prop.load(new FileInputStream("src\\druid.properties"));
 
        //获取连接池对象
        DataSource dataSource= DruidDataSourceFactory.createDataSource(prop);
 
        //获取数据库连接 Connection
        Connection connection=dataSource.getConnection();
 
        //定义sql语句
        String sql = "select * from tbl_brand";
 
        //获取PreparedStatement对象
        PreparedStatement pstmt = connection.prepareStatement(sql);
 
        //设置参数
 
        //执行sql
        ResultSet rs = pstmt.executeQuery();
 
        //处理结果 List<Brand> 封装brand对象 装载List集合
        List<Brand> brands=new ArrayList<>();
 
        while (rs.next()) {
            //获取数据
            int id = rs.getInt("id");
            String brandName = rs.getString("brand_name");
            String companyName = rs.getString("company_name");
            int ordered = rs.getInt("ordered");
            String description = rs.getString("description");
            int stauts = rs.getInt("status");
            //封装Brand对象
            Brand brand=new Brand(id,brandName,companyName,ordered,description,stauts);
            //装载集合
            brands.add(brand);
        }
 
        //打印集合
        for (Brand brand : brands) {
            System.out.println(brand);
        }
 
        //释放资源
        rs.close();
        pstmt.close();
        connection.close();
 
    }
 
}

测试通过

添加数据

我们查看一下页面原型

我们代码接收一个insert语句

插入数据就行

我们要插入除了id外的所有数据

id为递增且唯一

我们还是用PreparedStatement对象接收

我们以后在开发JDBC程序的时候

要注意三个事情

一个是SQL语句怎么书写

然后是要填入的参数

然后是返回值

例如这边的添加操作

package example;
 
import com.alibaba.druid.pool.DruidDataSourceFactory;
 
import org.junit.Test;
import pojo.Brand;
 
import javax.sql.DataSource;
import java.io.FileInputStream;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.ArrayList;
import java.util.List;
import java.util.Properties;
 
//增 添加数据
public class TestAdd {
 
    @Test
    public void testSelectAll() throws Exception {
 
        //模拟接收页面提交的数据
        String brandName="香飘飘";
        String companyName="香飘飘";
        int ordered=1;
        String description="绕地球一圈";
        int status=1;
 
        //insert into tbl_brand(brand_name,company_name,ordered,description,status) values(?,?,?,?,?);
        //参数 需要 除了id之外的所有参数信息
        //返回值 boolean
 
        System.out.println(System.getProperty("user.dir"));
 
        //获取连接
        Properties prop=new Properties();
        prop.load(new FileInputStream("src\\druid.properties"));
 
        //获取连接池对象
        DataSource dataSource= DruidDataSourceFactory.createDataSource(prop);
 
        //获取数据库连接 Connection
        Connection connection=dataSource.getConnection();
 
        //定义sql语句
        String sql = "insert into tbl_brand(brand_name,company_name,ordered,description,status) values(?,?,?,?,?);";
 
        //获取PreparedStatement对象
        PreparedStatement pstmt = connection.prepareStatement(sql);
 
        //设置参数
        pstmt.setString(1,brandName);
        pstmt.setString(2,companyName);
        pstmt.setInt(3,ordered);
        pstmt.setString(4,description);
        pstmt.setInt(5,status);
 
        //执行sql
        int count=pstmt.executeUpdate();  //影响的行数
 
        //处理结果
        System.out.println(count>0);
 
        //释放资源
        pstmt.close();
        connection.close();
 
    }
 
}

添加成功

修改数据

我们只是换了个SQL数据模型

和参数

即可

代码

package example;
 
import com.alibaba.druid.pool.DruidDataSourceFactory;
 
import org.junit.Test;
import pojo.Brand;
 
import javax.sql.DataSource;
import java.io.FileInputStream;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.ArrayList;
import java.util.List;
import java.util.Properties;
 
//改 修改数据
public class TestUpdate {
 
    @Test
    public void testUpdate() throws Exception {
 
        //模拟接收页面提交的数据
        String brandName="香飘飘";
        String companyName="香飘飘";
        int ordered=1;
        String description="绕地球三圈";
        int status=1;
        int id=1;
 
        //update tbl_brand set brand_name = ?,company_name=?,ordered=?,description=?,status=? where id =? ;
        //参数 需要 所有参数信息
        //返回值 boolean
 
        System.out.println(System.getProperty("user.dir"));
 
        //获取连接
        Properties prop=new Properties();
        prop.load(new FileInputStream("src\\druid.properties"));
 
        //获取连接池对象
        DataSource dataSource= DruidDataSourceFactory.createDataSource(prop);
 
        //获取数据库连接 Connection
        Connection connection=dataSource.getConnection();
 
        //定义sql语句
        String sql = "update tbl_brand set brand_name = ?,company_name=?,ordered=?,description=?,status=? where id =? ;";
 
        //获取PreparedStatement对象
        PreparedStatement pstmt = connection.prepareStatement(sql);
 
        //设置参数
        pstmt.setString(1,brandName);
        pstmt.setString(2,companyName);
        pstmt.setInt(3,ordered);
        pstmt.setString(4,description);
        pstmt.setInt(5,status);
        pstmt.setInt(6,id);
 
        //执行sql
        int count=pstmt.executeUpdate();  //影响的行数
 
        //处理结果
        System.out.println(count>0);
 
        //释放资源
        pstmt.close();
        connection.close();
 
    }
 
}

执行成功

瞅一眼数据库

成功修改

删除数据

不解释了

直接灵魂三问

改一下sql语句和获取PreparedStatement对象的参数即可

执行代码

package example;
 
import com.alibaba.druid.pool.DruidDataSourceFactory;
 
import org.junit.Test;
import pojo.Brand;
 
import javax.sql.DataSource;
import java.io.FileInputStream;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.ArrayList;
import java.util.List;
import java.util.Properties;
 
//增 添加数据
public class TestDelete {
 
    @Test
    public void testDelete() throws Exception {
 
        //模拟接收页面提交的数据
        int id=1;
 
        //delete from tbl_brand where id= ?
        //参数 需要id
        //返回值 boolean
 
        System.out.println(System.getProperty("user.dir"));
 
        //获取连接
        Properties prop=new Properties();
        prop.load(new FileInputStream("src\\druid.properties"));
 
        //获取连接池对象
        DataSource dataSource= DruidDataSourceFactory.createDataSource(prop);
 
        //获取数据库连接 Connection
        Connection connection=dataSource.getConnection();
 
        //定义sql语句
        String sql = "delete from tbl_brand where id= ?";
 
        //获取PreparedStatement对象
        PreparedStatement pstmt = connection.prepareStatement(sql);
 
        //设置参数
        pstmt.setInt(1,id);
 
        //执行sql
        int count=pstmt.executeUpdate();  //影响的行数
 
        //处理结果
        System.out.println(count>0);
 
        //释放资源
        pstmt.close();
        connection.close();
 
    }
 
}

删除成功

数据库中的数据成功删除

2024考古之还在用原始JDBC开发手搓案例实现一个模块的增删改

JDBC案例

准备环境

创建实体类

写测试用例

添加数据

修改数据

删除数据

热门文章

最新文章

相关课程

相关电子书

相关实验场景

热门

活动广场

任务中心

开发者评测

高校计划

乘风者计划

训练营

阿里云MVP

话题

直播

下载

镜像站

技术资料

插件

2024考古之还在用原始JDBC开发 手搓 案例 实现一个模块的增删改

JDBC案例

准备环境

创建实体类

写测试用例

添加数据

修改数据

删除数据

热门文章

最新文章

相关课程

相关电子书

相关实验场景

2024考古之还在用原始JDBC开发手搓案例实现一个模块的增删改