JDBC简述

Java如何连接数据库呢?

答案是:Java使用JDBC连接数据库。

那么JDBC又是什么?

Java数据库连接(Java Database Connectivity,简称JDBC)是Java语言中用来规范客户端程序如何来访问数据库的应用程序接口,提供了诸如查询和更新数据库中数据的方法。

对于不同的数据库,我们需要知道不同数据库对外提供的系统 API,这就影响了我们程序的扩展和跨平台的实现。JDBC为Java开发者使用数据库提供了统一的编程接口,它由一组java类和接口组成.是java程序与数据库系统通信的标准APl。 JDBC API使得开发人员可以使用纯 java 的方式来连接数据库,并执行操作。

对于我们自己写的程序这一端,接口是统一的,而对于不同数据库产品的连接是通过不同的 JDBC 类库实现的。

数据库接口图

MySQL编写基础

21分钟MySQL入门教程

使用JDBC访问数据库的流程

  1. 加载JDBC驱动
  2. 连接数据库
  3. 执行SQL查询
  4. 从结果集中提取数据
  5. 处理结果集
  6. 清理环境,关闭所有的数据库资源,释放内存

完整的测试代码:

    import java.sql.*;
    
    public class JdbcTest {
       // JDBC驱动器名称和数据库地址
       static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";  
       // 数据库的名称为EXAMPLE
       static final String DB_URL = "jdbc:mysql://localhost/EXAMPLE";
    
       // 数据库用户和密码
       static final String USER = "root";
    
       static final String PASS = "";
    
       public static void main(String[] args) {
       Connection conn = null;
       Statement stmt = null;
       try{

       //注册JDBC 驱动程序
       Class.forName("com.mysql.jdbc.Driver");
    
       //打开连接
       System.out.println("Connecting to database...");
       conn = DriverManager.getConnection(DB_URL,USER,PASS);
    
       //执行查询
       System.out.println("Creating statement...");
       stmt = conn.createStatement();
       String sql;
       sql = "SELECT id, name, age FROM Students";
       ResultSet rs = stmt.executeQuery(sql);
    
       //得到和处理结果集
       while(rs.next()){
       //检索
       int id  = rs.getInt("id");
       int age = rs.getInt("age");
       String name = rs.getString("name");
    
       //显示
       System.out.print("ID: " + id);
       System.out.print(", Age: " + age);
       System.out.print(", Name: " + name);
       System.out.println();
       }
       //清理环境
       rs.close();
       stmt.close();
       conn.close();
       }catch(SQLException se){
       // JDBC 操作错误
       se.printStackTrace();
       }catch(Exception e){
       // Class.forName 错误
       e.printStackTrace();
       }finally{
       //这里一般用来关闭资源的
       try{
       if(stmt!=null)
       stmt.close();
       }catch(SQLException se2){
       }
       try{
       if(conn!=null)
       conn.close();
       }catch(SQLException se){
       se.printStackTrace();
       }
       }
       System.out.println("Goodbye!");
       }
    }

注:上述测试代码基于已经使用MySQL建立了一个名为EXAMPLE的数据库和一张名为Students表的基础上。

步骤分解

导入JDBC驱动

只有拥有了驱动程序我们才可以注册驱动程序完成连接的其他步骤。

  1. 根据自己所使用的数据库类型和版本下载对应的驱动(本人数据库使用MySQL),MySQL的驱动包,其他请自行Google。

  2. 在Eclipse建立好的工程中导入下载好的MySQL驱动包

注册JDBC驱动程序

这一步会导致JVM加载所需的驱动程序实现到内存中,因此它可以实现JDBC请求。

  1. 注册一个驱动程序中最常用的方法是使用Java的Class.forName()方法来动态加载驱动程序的类文件到内存中,它会自动将其注册。不同的数据库有不同的装载方法。以下是装在MySQL驱动的代码:

     try {
        Class.forName("com.mysql.jdbc.Driver");
     }
     catch(ClassNotFoundException ex) {
        System.out.println("Error: unable to load driver class!");
        System.exit(1);
     }
    
  2. 数据库URL制定:创建具有正确格式的地址,指向到要连接的数据库。

     getConnection(String url)
     
     getConnection(String url, Properties prop)
     
     getConnection(String url, String user, String password)
     
     Mysql的URL是jdbc:mysql://hostname/ databaseName
    
  3. 创建连接对象:最后,代码调用DriverManager对象的getConnection()方法来建立实际的数据库连接。

     import java.sql.*;
         
     public class JdbcTest {
     // JDBC 驱动器的名称和数据库地址
     static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";  
     static final String DB_URL = "jdbc:mysql://localhost/EXAMPLE";
             
     static final String USER = "root";
     static final String PASS = "";
         
     public static void main(String[] args) {
     Connection conn = null;
     PreparedStatement stmt = null;
         
     //注册 JDBC 驱动器
     Class.forName("com.mysql.jdbc.Driver");
         
     //打开连接
     System.out.println("Connecting to database...");
     conn = DriverManager.getConnection(DB_URL,USER,PASS);
     System.out.println("Connecting Successful...");
        }
     }
    

执行SQL语句

Statement接口用于执行静态SQL语句并返回它所生成结果的对象。
三种Statement类:

  1. Statement: 由createStatement创建,用于发送简单的SQL语句。(不带参数的)
  2. PreparedStatement:继承自Statement接口,由prepareStatement创建,用于发送含有一个或多个输入参数的sql语句。PreparedStatement对象,会进行预编译,比Statement对象的效率更高,并且可以防止SQL注入。我们一般都使用PreparedStatement。

  3. CallableStatement: 继承自PreparedStatement,由方法prePareCall创建,用于调用存储过程。

常用的Statement方法:

  1. execute():运行语句,返回是否有结果集。
  2. executeQuery():运行select语句,返回ResultSet结果集。
  3. executeUpdate():运行insert/update/delete操作,返回更新的行数。

提取并处理查询结果

Statement执行SQL语句时,返回ResultSet结果集。

ResultSet提供的检索不同类型字段的方法,常用的有:

  1. getString():获得在数据库里varchar、char等数据类型的对象。
  2. getFloat():获得在数据库里Float类型的对象。
  3. getDate():获得在数据库里Date类型的数据。
  4. getBoolean():获得在数据库里面Boolean类型的数据。

关闭数据库连接,释放内存。

关闭服务的顺序和连接刚好相反。先清理查询所占用的内存,再关闭数据库连接。

文章来源于互联网:Java MySQL连接

发表评论