码迷,mamicode.com
首页 > 数据库 > 详细

使用原生JDBC方式对数据库进行操作

时间:2020-01-01 20:56:20      阅读:191      评论:0      收藏:0      [点我收藏+]

标签:table   string   tree   char   code   name   cto   加载驱动   gis   

使用原生JDBC方式对数据库进行操作,包括六个步骤:

1.加载JDBC驱动程序

    在连接数据库之前,首先要加载想要连接的数据库的驱动到JVM。可以通过java.lang.Class类的静态方法forName(String className)实现,成功加载后,会将Driver类的实例注册到DriverManager类中。

    代码如下:

Class.forName("com.mysql.jdbc.Driver");

    Class.forName()方法内部实现包括两部分:类加载、类初始化。

    1)类加载

     当使用一个类的时候(比如 new 一个类的实例),会检查此类是否被加载到内存,如果没有,则会执行加载操作。读取类对应的 class 文件数据,解析此数据,构造一个此类对应的 Class 类的实例。类加载好了以后,JVM就可以使用该类了,比如实例化此类,或者调用此类的静态方法。

     Java 也提供了手动加载类的接口,class.forName()方法就是其中之一。

    2)类初始化

    类被加载之后,jvm 已经获得了一个描述类结构的 Class 实例。但是还需要进行类初始化操作之后才能正常使用此类,类初始化操作就是执行一遍类的静态语句,包括静态变量的声明还有静态代码块。

    MySQL 的 Driver 类中,在静态代码块中,就通过 JDBC 的 DriverManager 注册了驱动。代码如下:

public class Driver extends NonRegisteringDriver implements java.sql.Driver {
  
static {
    try {
        java.sql.DriverManager.registerDriver(new Driver());
    } catch (SQLException E) {
        throw new RuntimeException("Can‘t register driver!");
    }
}
  
    public Driver() throws SQLException {
    // Required for Class.forName().newInstance()
    }
}

 

2.创建数据库的连接

JDBC连接的URL书写形式:协议:子协议:数据源标识 。

其中:

     协议:在JDBC中总是以jdbc开始 。子协议:是桥连接的驱动程序或是数据库管理系统名称。  数据源标识:标记找到数据库来源的地址与连接端口。

String URL = "jdbc:mysql://127.0.0.1:3306/mybatis?characterEncoding=utf-8";
String USER = "root";
String PASSWORD = "123456";

创建数据库连接的代码:

Connection conn = DriverManager.getConnection(URL, USER, PASSWORD);

 

3.创建Statement

要执行SQL语句,必须获得java.sql.Statement实例,Statement实例分为以下3 种类型:

  •     执行静态SQL语句。通常通过Statement实例实现。
  •     执行动态SQL语句。通常通过PreparedStatement实例实现。
  •     执行数据库存储过程。通常通过CallableStatement实例实现。

代码如下:

String name = "中国";
//预编译
String sql = "select * from country where countryname=?";
PreparedStatement statement = conn.prepareStatement(sql);
statement.setString(1, name);

 

4.执行SQL语句

Statement接口提供了三种执行SQL语句的方法:executeQuery 、executeUpdate   和execute  

  •     ResultSet executeQuery(String sqlString):执行查询数据库的SQL语句   ,返回一个结果集(ResultSet)对象。
  •     int executeUpdate(String sqlString):用于执行INSERT、UPDATE或   DELETE语句以及SQL DDL语句,如:CREATE TABLE和DROP TABLE等  
  •     execute(sqlString):用于执行返回多个结果集、多个更新计数或二者组合的   语句。

代码如下:

ResultSet rs = statement.executeQuery();

 

5.处理结果 

两种情况:  

  •     执行更新返回的是本次操作影响到的记录数。  
  •     执行查询返回的结果是一个ResultSet对象。  

     ResultSet包含符合SQL语句中条件的所有行,并且它通过一套get方法提供了对这些行中数据的访问。

    使用结果集(ResultSet)对象的访问方法获取数据,代码如下:

while (rs.next()) {
logger.info(rs.getString("countryname") + " " + rs.getString("countrycode"));
}

 

6.关闭JDBC对象

操作完成以后要把所有使用的JDBC对象全都关闭,以释放JDBC资源,关闭顺序和声明顺序相反:

  •     关闭记录集
  •     关闭声明  
  •     关闭连接对象

代码如下:

rs.close();
statement.close();
conn.close();

 

7.原生JDBC访问类

全部代码如下:

package com.taoxi.study.jdbc;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.sql.*;

public class NativeJDBC {

    private static Logger logger = LoggerFactory.getLogger(NativeJDBC.class);

    public static void query() throws Exception {
        String URL = "jdbc:mysql://127.0.0.1:3306/mybatis?characterEncoding=utf-8";
        String USER = "root";
        String PASSWORD = "123456";
        // 1.加载驱动程序
        try {
            Class.forName("com.mysql.jdbc.Driver");
            // 2.获得数据库链接
            Connection conn = DriverManager.getConnection(URL, USER, PASSWORD);
            // 3.通过数据库的连接操作数据库,实现增删改查(使用Statement类)
            String name = "中国";
            //预编译
            String sql = "select * from country where countryname=?";
            PreparedStatement statement = conn.prepareStatement(sql);
            statement.setString(1, name);
            ResultSet rs = statement.executeQuery();

            // 4.处理数据库的返回结果(使用ResultSet类)
            while (rs.next()) {
                logger.info(rs.getString("countryname") + " " + rs.getString("countrycode"));
            }

            // 关闭资源
            rs.close();
            statement.close();
            conn.close();
        } catch (ClassNotFoundException e) {
            logger.error("error:", e);
            throw e;
        } catch (SQLException e) {
            logger.error("error:", e);
            throw e;
        }
    }

}

完整项目的github地址:https://github.com/taoxibj/study/tree/master/jdbc

 

  

使用原生JDBC方式对数据库进行操作

标签:table   string   tree   char   code   name   cto   加载驱动   gis   

原文地址:https://www.cnblogs.com/windpoplar/p/12129513.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!