JDBC的介绍与使用

1. JDBC的介绍

jdbc为java开发者使用数据库提供了统一的编程接口，它由一组java类和接口组成。
访问数据库的流程
JDBC的介绍与使用
在连接这一过程中，一般初学者是MySQL和java在同一个电脑上，建立socket连接。
常用接口：- 一般针对java开发使用 Driver接口就行，- 在连接数据库时，需要装载特定厂商的数据驱动程序：
MySQL：Class.forname(‘com.mysql.jdbc.Driver’);
Oracle：Class.forname(‘oracle.jdbc.driver.OracleDriver’);

创新互联专注为客户提供全方位的互联网综合服务，包含不限于成都做网站、网站建设、永安网络推广、微信小程序、永安网络营销、永安企业策划、永安品牌公关、搜索引擎seo、人物专访、企业宣传片、企业代运营等，从售前售中售后，我们都将竭诚为您服务，您的肯定，是我们最大的嘉奖；创新互联为所有大学生创业者提供永安建站搭建服务，24小时服务热线：18980820575，官方网址：www.cdcxhl.com

2.JDBC重要的API（以MySQL为例）

建立连接：

 @Test
    public void getConnect(){
        try {
            //加载驱动
            Class.forName("com.mysql.jdbc.Driver");
            //获取连接
            String url="jdbc:mysql://localhost:3306/library";
            String user="root";
            String password="123456";
            Connection connection = DriverManager.getConnection(url, user, password);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

Statement
注意：这里Statement- 用于执行静态SQL语句并返回它所生成的结果对象，这里的Statement有三个类：
- Statement由createStatement创建，用于发送简单的SQL语句。（不带参）
- PreparedStatement：继承自Statement父类，由preparedStatement创建，用于发送含有一个或多个输入参数的SQL语句。PreparedStatement对象比Statement对象效率更高，并且可以防止SQL注入。
- CallableStatement:继承自PreparedStatement。由方法prePareCall创建，用于调用存储。
常用的Statement的方法有：
- execute（）：运行语句，返回是否有结果集
- executeQuery（）：运行select语句，返回ResultSet结果集
- executeUpdate（）：运行insert/update/delete操作，返回影响的行数
相关代码：

@Test
    public void testStatement() throws SQLException {
        //创建Statement
        Statement statement = connection.createStatement();
        String sql="select * from book";
        boolean  isNull= statement.execute(sql);

        //创建PreparedStatement
        sql="select * from book";
        PreparedStatement preparedStatement1 = connection.prepareStatement(sql);
        ResultSet resultSet = preparedStatement1.executeQuery();

        //PreparedStatement防止SQL注入,这里的?表示占位符
        sql="select * from book where bid = ?";
        PreparedStatement preparedStatement2 = connection.prepareStatement(sql);
        preparedStatement2.setObject(1,2);
        preparedStatement2.executeQuery();
    }

ResultSet
描述：ResultSet 主要是由executeQuery（）方法执行返回
读取数据的流程图：
JDBC的介绍与使用
例：

    @Test
    public void testStatement() throws SQLException {
        //创建PreparedStatement
        String sql = "select * from book";
        PreparedStatement preparedStatement1 = connection.prepareStatement(sql);
        ResultSet resultSet = preparedStatement1.executeQuery();
        while(resultSet.next()){ //表示是否还有下一个
            System.out.println("bid"+resultSet.getInt(1));
            System.out.println("bname"+resultSet.getString(2));
            System.out.println("author"+resultSet.getString(3));
        }
    }

jdbc的批处理

注意：如果使用大量的批处理时，建议使用statement，因为preparedstatement的预编译空间有限，当数据量特别大时，会发生异常。
例：

@Test
public void testStatement() throws SQLException {
    //创建Statement
    Statement statement = connection.createStatement();
    for (int i = 0; i < 50; i++) {
        //获得当前的系统时间
        long timestamp = System.currentTimeMillis();
        String sql = "insert into t_date(t_time,t_id) values(" + timestamp + "," + i + ")";
        //为批处理添加执行的SQL语句
        statement.addBatch(sql);
    }
    //执行批处理
    statement.executeBatch();
    //提交事务
    connection.commit();
}

jdbc的事务

@Test
public void testTransaction() {
    //取消自动提交
    try {
        connection.setAutoCommit(false);
        //插入一条DML语句
        PreparedStatement stetm1 = connection.prepareStatement("insert into book values(1001,'朝花夕拾','鲁迅')");
        stetm1.execute();

        //插入另条DML语句
        PreparedStatement stetm2 = connection.prepareStatement("insert into book values(1001,'海贼王','尾田一郎')");
        stetm2.execute();

        //提交
        connection.commit();

    } catch (SQLException e) {
        try {
            //失败后自动回滚
            connection.rollback();
        } catch (SQLException e1) {
            e1.printStackTrace();
        }
        e.printStackTrace();
    }
}

CLOB操作：
用于存储大量的文本数据，大字段的操作常常以流的方式处理。而非一般的字段一次读取即可。
JDBC的介绍与使用

//代码实现：
public class ReadAndWriteClob {
    public static void main(String[] args) {
        //获取数据库连接
        try {
            Class.forName("com.mysql.jdbc.Driver");
            Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/library",
                    "root",
                    "123456");
            //clob字段插入
            //表：user_info
            //字段：name varchar , introduce  clob
            String sql = "insert into user_info values(?,?)";
            PreparedStatement prepared1 = conn.prepareStatement(sql);
            //插入数据
            prepared1.setObject(1, "user1");
            //设置插入文本对象，第二个参数是一个输入流，直接读取文件
            prepared1.setClob(2,new BufferedReader(
                    new InputStreamReader(
                            new FileInputStream("src/a.txt"))));
            prepared1.execute();
            //clob字段读取
            sql="select * from user_info";
            PreparedStatement prepared2 =conn.prepareStatement(sql);
            ResultSet resultSet = prepared2.executeQuery();
            while(resultSet.next()){
                Clob introduce = resultSet.getClob("introduce");
                Reader characterStream = introduce.getCharacterStream();
                int temp=0;
                while((temp=characterStream.read())!=-1){
                    System.out.print((char)temp);
                }
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

BLOB操作：
用于存储大量的二进制数据，二进制可以存入任何类型的文件（音频、视频等等..）。
JDBC的介绍与使用

//代码实现
public class ReadAndWriteClob {
    public static void main(String[] args) {
        //获取数据库连接
        try {
            Class.forName("com.mysql.jdbc.Driver");
            Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/library",
                    "root",
                    "123456");
            //clob字段插入
            //表：user_info
            //字段：name varchar , headImg  blob
            String sql = "insert into user_info values(?,?)";
            PreparedStatement prepared1 = conn.prepareStatement(sql);
            //插入数据
            prepared1.setObject(1, "user1");
            //设置插入图片对象，第二个参数是一个基本输入流
            prepared1.setBlob(2,new FileInputStream("src/a.jpg"));
            prepared1.execute();
            //clob字段读取
            sql="select * from user_info";
            PreparedStatement prepared2 =conn.prepareStatement(sql);
            ResultSet resultSet = prepared2.executeQuery();
            while(resultSet.next()){
                Blob headImg = resultSet.getBlob("headImg");
                //获取的是基本的流，
                InputStream binaryStream = headImg.getBinaryStream();
                int len=0;
                byte flush []=new byte [1025];
                OutputStream os=new FileOutputStream(new File("d:\\c.jpg"));
               while((len=binaryStream.read(flush))!=-1){
                   os.write(flush,0,len);
                   os.flush();
               }
                os.close();
                binaryStream.close();
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

对jdbc的封装
这里需要加载配置文件：
JDBC的介绍与使用
代码实现：

public class jdbcUtils {
    private static Properties pro;

    static {
        try {
            pro = new Properties();
            InputStream in = jdbcUtils.class.getClassLoader().getResourceAsStream("dbproperties.properties");
            pro.load(in);
            Class.forName(pro.getProperty("driver"));
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
    //建立与数据库的连接
    public static Connection getMySQLConn(){
        try {
            return DriverManager.getConnection(pro.getProperty("url"),
                    pro.getProperty("user"),
                    pro.getProperty("password"));
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return null;
    }

    /**
     * 关闭顺序：resultSet --preparStatement -- Connection
     * 在关闭时，不能讲这三者的close()写在同一个try{}catch{}中
     */
    public static void close(Statement stem,ResultSet rs,Connection conn){
        if(rs!=null){
            try {
                rs.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        if(stem!=null){
            try {
                stem.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        if(conn!=null){
            try {
                conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}

分享文章：JDBC的介绍与使用
文章网址：http://chengdu.cdxwcx.cn/article/pjcegi.html

甜橘子，专注成都网站制作网站设计与营销型网站建设与优化

首页

网站建设

网站制作案例

解决方案

网站设计报价

网站制作动态

关于我们

联系我们

成都网站建设设计将想法与焦点和您一起共享

JDBC的介绍与使用

1. JDBC的介绍

2.JDBC重要的API（以MySQL为例）

其他资讯

怎么检测mysql数据库检查mysql是否正常

vb点虐类型转换函数 vb60转net

vb点虐滚动条容器 vb滚动条的使用

php在链接里传输数据库 php连接数据库的方法

云服务器入门阿里云服务器阿里云服务器百度百科

甜橘子，专注成都网站制作网站设计与营销型网站建设与优化

成都网站建设设计 将想法与焦点和您一起共享

JDBC的介绍与使用

1. JDBC的介绍

2.JDBC重要的API（以MySQL为例）

其他资讯

怎么检测mysql数据库 检查mysql是否正常

vb点虐 类型转换函数 vb60转net

vb点虐 滚动条容器 vb滚动条的使用

php在链接里传输数据库 php连接数据库的方法

云服务器入门阿里云服务器 阿里云服务器百度百科

成都网站建设设计将想法与焦点和您一起共享

怎么检测mysql数据库检查mysql是否正常

vb点虐类型转换函数 vb60转net

vb点虐滚动条容器 vb滚动条的使用

云服务器入门阿里云服务器阿里云服务器百度百科