美文网首页
JDBC整理记录

JDBC整理记录

作者: livesxu | 来源:发表于2020-08-29 22:44 被阅读0次

1.什么是JDBC?

Java DataBase Connectivity Java 数据库连接
其实就是官方(sun公司)定义的一套操作所有关系型数据库的规则,即接口。各个数据库厂商去实现这套接口,提供数据库驱动jar包。我们可以使用这套接口(JDBC)编程,真正去执行的代码式驱动jar包的实现类。

2.步骤:

a.导入驱动jar包,需要Add As Library
b.注册驱动对象

mysql注册驱动:mysql5之后的jar包可以省略注册驱动的步骤
Class.forName("com.mysql.cj.jdbc.Driver");

c.定义数据库连接对象 Connection

Connection connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/dbtest","root","bbobbo24");

d.定义sql语句

String sqlString = "delete from tbtest where id = 8;";

e.获取执行sql语句的对象 Statement

Statement statement = connection.createStatement();

f.执行sql,接收返回结果

int count = statement.executeUpdate(sqlString);

g.处理结果

if (count > 0) {
    System.out.println("操作成功");
} else {
    System.out.println("操作失败");
}

h.释放资源

if (connection != null) {
    try {
        connection.close();
     }catch (SQLException e) {
     }
}
if (statement != null) {
    try {
       statement.close();
    } catch (SQLException e) {
    }
}

3.数据库连接对象 Connection

1.获取执行sql的对象Statement
a. createStatement
b. prepareStatement(String sqlString) 可以防止SQL注入,效率更高

String sqlString = "select * from tbtest where worker=? and score > ?;";
preparedStatement = connection.prepareStatement(sqlString);
preparedStatement.setInt(1,2);
preparedStatement.setDouble(2,80);
resultSet = preparedStatement.executeQuery();
while (resultSet.next()) {
      System.out.println(resultSet.getInt("id") + " " + resultSet.getString("name"));
}

2.管理事务:

  • 开启事务:setAutoCommit(false);
  • 提交事务:commit();
  • 回滚事务:rollback(); 判空&&异常
try {
    // 开启事务
    connection.setAutoCommit(false);
    statement = connection.createStatement();
    statement.executeUpdate("update tbtest set score = score + 5 where score > 80;");
    //如果这儿发生了一个错误
    statement.executeUpdate("update tbtest set score = score - 5 where score < 80;");
    //提交事务
    connection.commit();
    System.out.println("成绩更新成功");
 } catch (Exception exception) {
    if (connection != null) {
        try {
        //回滚事务
        connection.rollback();
        System.out.println("回滚事务");
        } catch (Exception exception1) {
        }
    }
    System.out.println(exception.getMessage());
 }

4.Statement 执行sql的对象

  • execute 可以执行任意sql
  • int executeUpdate 执行DML(insert、update、delete)、DDL(create、alter、drop)
  • ResultSet executeQuery 执行DQL(select)

5.结果集对象 ResultSet

  • next(); 游标向下移动一行,当查询结果是个表时游标在表第一行,判断当前行是否是最后一行
  • getXxx(参数):获取数据
    a. 可以传值列的编号 从1开始 getString(2)
    b. 传值列的名称推荐 getString("name")
resultSet = preparedStatement.executeQuery();
while (resultSet.next()) {
      System.out.println(resultSet.getInt("id") + " " + resultSet.getString("name"));
}

6数据库连接池

  • 节约资源
  • 用户访问高效
    1.使用:DataSource
    a. 获取连接 dataSource.getConnection()
    b. 归还连接 connection.close(); //如果连接对象Connection是从连接池获取那么close将不是关闭连接,而是归还。
  1. Druid:数据库连接池实现技术,由阿里巴巴提供
    a. 导入jar包 地址
    b. 定义配置文件properties
driverClassName=com.mysql.cj.jdbc.Driver
url=jdbc:mysql://localhost:3306/dbtest
username=root
password=xxxxxx
#初始化连接数量
initialSize=5
#最大连接数
maxActive=20
#最大等待时间
maxWait=3000

c. 加载配置文件
d. 获取数据库连接池对象 DruidDataSourceFactory
e. 获取连接

Properties properties = new Properties();
InputStream inputStream = ConneFour.class.getClassLoader().getResourceAsStream("druid.properties");
properties.load(inputStream);
DataSource dataSource = DruidDataSourceFactory.createDataSource(properties);
Connection connection = dataSource.getConnection();
System.out.println(connection);
Statement statement = connection.createStatement();
ResultSet resultSet = statement.executeQuery("select * from tbtest;");
while (resultSet.next()) {
    System.out.println(resultSet.getInt(1) + " " + resultSet.getString(2));
}

7.Spring JDBC

Spring 框架对 JDBC 的封装,提供了一个 JdbcTemplate对象简化JDBC开发
a. 导入jar包 地址

  • spring-beans
  • spring-core
  • spring-jdbc
  • spring-tx
  • com.springsource.org.apache.commons.logging-1.1.1

b.创建JdbcTemplate,依赖于数据源DataSource

JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);

c.执行CRUD

  • update() 执行DML语句
  • queryForMap() 查询结果,将结果封装成map集合 这个方法查询的结果集长度只能为1,列名作为key,值为value,将这条记录封装成map集合
  • queryForList() 查询结果,将结果封装成list集合 将其中每一条记录封装成map
  • query() 查询结果,将结果封装为JavaBean对象
  • queryForObject() 查询结果,将结果封装成对象
//int infos = jdbcTemplate.update("update tbtest set score=100 where id=1;");
//Map infos = jdbcTemplate.queryForMap("select * from tbtest where id=1;");
//List infos = jdbcTemplate.queryForList("select * from tbtest;");
List<TbInfoBean> infos = jdbcTemplate.query("select * from tbtest;",new BeanPropertyRowMapper<TbInfoBean>(TbInfoBean.class));

相关文章

  • JDBC整理记录

    1.什么是JDBC? Java DataBase Connectivity Java 数据库连接其实就是官方(su...

  • JDBC 编程学习

    前言 将最近学习的JDBC编程整理成笔记,做次记录。 mysql 安装 首先安装mysql 8.0.19 版本数据...

  • JDBC基础整理

    简介 JDBC:java database connectivity SUN公司提供的一套操作数据亏的标准规范.J...

  • MyBatis内容整理

    MyBatis内容整理 1、关于JDBC 项目中使用了8.0.9版本的JDBC,在配置JDBC相关的数据库连接时,...

  • 轻松理解JDBC并使用

    一.前言 最近学习了JDBC,觉得非常重要,因此连忙熬夜记录下来。 二.什么是JDBC? JDBC(Java Da...

  • mybatis入门之增删改查

    一、原生态JDBC程序中问题的总结 1.1 JDBC程序 需求:使用jdbc查询mysql数据库中用户的记录Sta...

  • JDBC学习记录

    jdbc学习 认真的回顾一下jdbc。巩固一下知识。争取用最通俗的话来解释。 首先我们在编程中肯定是要用到数据库的...

  • JDBC学习记录

    JDBC连接数据库 1.加载驱动程序 2.创建连接对象 3.创建sql语句执行对象 Statement类 分为:S...

  • Sharding-JDBC自定义复合分片算法

    一、背景 最近在看 Sharding-JDBC方面的内容,此处简单记录一下使用Sharding-JDBC中的复合分...

  • java进阶学习整理JDBC

    1.认识JDBC JDBC(Java Data Base Connectivity,java数据库连接)是一种用于...

网友评论

      本文标题:JDBC整理记录

      本文链接:https://www.haomeiwen.com/subject/ingdsktx.html