Java学习(十四)：JDBC方式连接数据库举例

java定义了JDBC这一标准的接口和类，为程序员操作数据库提供了统一的方式。

下载对应数据库的jar包，添加到工程内。

JDBC的操作方式比较单一，由五个流程组成：

1.通过数据库厂商提供的JDBC类库向DriverManager注册数据库驱动

2.使用DriverManager提供的getConnection()方法连接到数据库

3.通过数据库的连接对象的createStatement方法建立SQL语句对象

4.执行SQL语句，并将结果集合返回到ResultSet中

5.使用while循环读取结果

6.关闭数据库资源

代码举例

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class TestJDBC
{
    private final static String url = "jdbc:mysql://localhost:3306/test";
    
    private final static String user = "";
    
    private final static String password = "";
    
    public static void main(String[] args)
    {
        ResultSet rs = null;
        Statement stmt = null;
        
        // jdbc驱动加载
        driverLoader();
        // 获取数据库连接
        Connection conn = connectionGet();
        try
        {
            stmt = conn.createStatement();
            String sql = "select * from ljf";
            rs = stmt.executeQuery(sql);
            while (rs.next())
            {
                System.out.print(rs.getInt("id") + "   ");
                System.out.print(rs.getString("name") + "   ");
            }
        }
        catch (SQLException e)
        {
            System.out.println("数据操作错误");
            e.printStackTrace();
        }
        finally
        {
            // 关闭数据库
            close(rs, stmt, conn);
        }
    }
    
    private static void driverLoader()
    {
        try
        {
            Class.forName("com.mysql.jdbc.Driver"); // 加载mysql驱动
        }
        catch (ClassNotFoundException e)
        {
            System.out.println("驱动加载错误");
            e.printStackTrace();
        }
    }
    
    private static Connection connectionGet()
    {
        Connection conn = null;
        try
        {
            conn = DriverManager.getConnection(url, user, password);
        }
        catch (SQLException e)
        {
            System.out.println("数据库链接错误");
            e.printStackTrace();
        }
        return conn;
    }
    
    private static void close(ResultSet rs, Statement stmt, Connection conn)
    {
        try
        {
            if (rs != null)
            {
                rs.close();
                rs = null;
            }
            if (stmt != null)
            {
                stmt.close();
                stmt = null;
            }
            if (conn != null)
            {
                conn.close();
                conn = null;
            }
        }
        catch (Exception e)
        {
            System.out.println("数据库关闭错误");
            e.printStackTrace();
        }
    }
}