Java MySQL连接

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访问数据库的流程

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

完整的测试代码：

    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驱动

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

根据自己所使用的数据库类型和版本下载对应的驱动（本人数据库使用MySQL），MySQL的驱动包，其他请自行Google。
在Eclipse建立好的工程中导入下载好的MySQL驱动包

注册JDBC驱动程序

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

注册一个驱动程序中最常用的方法是使用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);
 }
```

数据库URL制定：创建具有正确格式的地址，指向到要连接的数据库。

 getConnection(String url)
 
 getConnection(String url, Properties prop)
 
 getConnection(String url, String user, String password)
 
 Mysql的URL是jdbc:mysql://hostname/ databaseName

创建连接对象：最后，代码调用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类：

Statement：由createStatement创建，用于发送简单的SQL语句。（不带参数的）
PreparedStatement：继承自Statement接口，由prepareStatement创建，用于发送含有一个或多个输入参数的sql语句。PreparedStatement对象,会进行预编译，比Statement对象的效率更高，并且可以防止SQL注入。我们一般都使用PreparedStatement。
CallableStatement：继承自PreparedStatement，由方法prePareCall创建，用于调用存储过程。

常用的Statement方法：

execute()：运行语句，返回是否有结果集。
executeQuery()：运行select语句，返回ResultSet结果集。
executeUpdate()：运行insert/update/delete操作，返回更新的行数。

提取并处理查询结果

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

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

getString()：获得在数据库里varchar、char等数据类型的对象。
getFloat()：获得在数据库里Float类型的对象。
getDate()：获得在数据库里Date类型的数据。
getBoolean()：获得在数据库里面Boolean类型的数据。

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

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