01.JDBC概念梳理

SQL语句执行流程

JDBC执行数据库操作语句,首先需要将sql语句打包成为网络字节流,传递给数据库,数据库经过解包,然后编译sql语句,最后执行,然后将结果通过字节流的形式返回给JDBC API

简单的来说大致分为以下几点:

  • JDBC打包sql语句

  • 发送字节流至数据库

  • 数据库解包

  • 检查sql语法,编译sql

  • 执行sql语句

  • 将sql语句返回给JDBC 接口
    <br/>

    数据库的链接步骤

    <br/>

  • 注册驱动 (Driver)

  • 建立连接(创建Connection)

  • 创建执行sql语句(通常是创建Statement或者其子类)

  • 执行语句

  • 处理执行结果(在非查询语句中,该步骤是可以省略的)

  • 释放相关资源

案例

    @Test
    public void wholeExample(){
        try {
            //1.注册驱动
            Class.forName("com.mysql.jdbc.Driver");
            //2.获取数据库连接
            Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/test", "root","123456");
            //3.创建执行句柄
            Statement stmt = conn.createStatement();
            //4.执行sql语句
            ResultSet rs = stmt.executeQuery("select * from user");
            //5.处理执行结果
            while(rs.next()){
                System.out.println("id:"+rs.getInt(1)+"/tname:"+rs.getString(2)+"/tbirthday:"+rs.getDate(3)+"/tmoney:"+rs.getFloat(4));
            }
            //6.释放资源
            rs.close();
            stmt.close();
            conn.close();
        } catch (SQLException e) {
            e.printStackTrace();
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        }
    }

数据类型

<br/>

CLOB

当我们存放大量的文本信息时,数据库中的varchar或者varchar2肯定是不能满足的,varchar2好像最多只能有4000个长度,存放一篇很长的文章或者一个文本信息,我们采用CLOB类型

BLOB

针对二进制文件进行的存取,比如图片,音频等信息

//stream文件流
PreparedStatement.setBlob(index, stream)

SQL数据类型与Java数据类型

<br/>

01.JDBC概念梳理

事务

数据库的事务是保证数据完整性的一种机制,简而言之,就是怎样确保数据的执行过程要么都成功,要么都失败

ACID机制

<br/>

  • 原子性(atomicity):组成事务处理的语句形成了一个逻辑单元,不能只执行其中的一部分

  • 一致性(consistency):在事务处理执行前后,数据库是一致的(两个账户要么都变,或者都不变)

  • 隔离性(isolcation):一个事务处理对另一个事务处理没有影响

  • 持续性(durability):事务处理的效果能够被永久保存下来

Jdbc的事务默认是打开的,也就是说执行每一步操作的话,事务都会隐式的进行提交,在抛出异常之前,我们的更改操作已经同步到了数据库中去

事务控制函数

//提交事务

  • connection.commit();

//回滚事务

  • connection.rollback();

分布式事务

通常所说的跨库事务,要求几个数据库的事务在一个应用中保持一致,JTA就是为了解决这个问题而诞生的

PreparedStatement接口

在数据库操作中PreparedStatement会带来很大的方便,减少拼写sql字符串带来的麻烦,防止SQL注入的发生.

  • PreparedStatement是Statement的子类

  • PreparedStatement是一个预处理命令的Statement实现

CallableStatement接口

在数据库操作中调用数据库中的存储过程

案例:执行有参数有返回值的存储过程

  • 创建一个存储过程
create or replace procedure test1(in id integer,in name varchar(20),in money float,out counter integer)
as
begin
    insert into user values(id,name,now(),money);
    select count(1) into counter from user;
    commit;
end test1;
  • 编写测试代码,在需要将值返回时,需要对其进行注册
    @Test
    public void callProcedureWithParamWithResult() throws SQLException{
        Connection conn = null;
        CallableStatement stmt = null;
        ResultSet rs = null;
        try {
            conn = ConnCreate.getConnection("jdbc:mysql://localhost:3306/test",
                    "root", "123456");
            String sql = "{call test1(?,?,?,?)}";
            stmt = conn.prepareCall(sql);
            stmt.setInt(1, 17);
            stmt.setString(2, "test");
            stmt.setFloat(3, 6000);
            stmt.registerOutParameter(1, Types.INTEGER);
            stmt.executeUpdate();
            int counter = stmt.getInt(4);
            System.out.println(counter);
        } finally {
            ConnCreate.close(conn, stmt, rs);
        }
    }

批处理

<br/>
//添加一条条的sql

  • stmt.addBatch(sql)

// 执行批处理

  • stmt.executeBatch()
    <br/>

    分页技术

利用sql语句进行分页(eg: mysql的limit ? ?, 一个offsize偏移量,另一个pagesize页面数量)

 @Test
    public void page() throws SQLException{
        page(100,20);
    }

    static void page(int start,int total) throws SQLException{
        Connection conn = null;
        PreparedStatement stmt = null;
        ResultSet rs = null;
        try {
            conn = ConnCreate.getConnection("jdbc:mysql://localhost:3306/test",
                    "root", "123456");
            String sql = "select * from user limit ?,?";
            stmt = conn.prepareStatement(sql);
            stmt.setInt(1, start);
            stmt.setInt(2, total);
            rs = stmt.executeQuery();
            while(rs.next()) //向下滚动
            {
                System.out.println("name:"+rs.getString(2)+"id:"+rs.getInt(1));
            }
        } finally {
            ConnCreate.close(conn, stmt, null);
        }
    }

连接池

使用jdbc最大的开销之一就是创建数据库,当我们频繁的创建数据库时,势必影响应用的效率,或者在数据库关闭出现问题时,我们不能马上释放,时间长一些,整个数据库的 资源将会被我们的应用耗尽

  • C3P0

  • DBCP

ResultSetMetaData

如果我们不知道我们的一个sql语句查询了几列结果集,并且每列的列名,类型等信息,这个时候我们应该使用ResultSetMetaData

01.JDBC概念梳理

<br/>

案例

 @Test
    public void resultMeta() throws SQLException{
        String sql="select * from user";
        Connection conn = null;
        PreparedStatement stmt = null;
        ResultSet rs = null;
        try {
            conn = ConnFactory.getConnection();
            stmt = conn.prepareStatement(sql);
            rs = stmt.executeQuery();
            ResultSetMetaData rsmd = rs.getMetaData();
            int count = rsmd.getColumnCount();
            for(int i=1;i<=count;++i){
                System.out.println("Type:"+rsmd.getColumnType(i));
                System.out.println("ColumnName:"+rsmd.getColumnName(i));
                System.out.println("ColumnLable:"+rsmd.getColumnLabel(i));
            }
        } finally{
            ConnFactory.close(conn, stmt, rs);
        }

    }

原创文章,作者:3628473679,如若转载,请注明出处:https://blog.ytso.com/197809.html

(0)
上一篇 2021年11月17日
下一篇 2021年11月17日

相关推荐

发表回复

登录后才能评论