JDBC是怎么和数据库建立连接的

创建一个以JDBC连接数据库的程序，包含7个步骤：

1、加载JDBC驱动程序：

在连接数据库之前，首先要加载想要连接的数据库的驱动到JVM（Java虚拟机），

这通过java.lang.Class类的静态方法forName(String className)实现。

例如：

try{

//加载MySql的驱动类

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

}catch(ClassNotFoundException e){

System.out.println("找不到驱动程序类 ，加载驱动失败！")

e.printStackTrace()

}

成功加载后，会将Driver类的实例注册到DriverManager类中。

2、提供JDBC连接的URL

•连接URL定义了连接数据库时的协议、子协议、数据源标识。

•书写形式：协议：子协议：数据源标识

协议：在JDBC中总是以jdbc开始

子协议：是桥连接的驱动程序或是数据库管理系统名称。

数据源标识：标记找到数据库来源的地址与连接端口。

例如：（MySql的连接URL）

jdbc:mysql:

//localhost:3306/test?useUnicode=true&characterEncoding=gbk

useUnicode=true：表示使用Unicode字符集。如果characterEncoding设置为

gb2312或GBK，本参数必须设置为true 。characterEncoding=gbk：字符编码方式。

3、创建数据库的连接

•要连接数据库，需要向java.sql.DriverManager请求并获得Connection对象，

该对象就代表一个数据库的连接。

•使用DriverManager的getConnectin(String url , String username ,

String password )方法传入指定的欲连接的数据库的路径、数据库的用户名和

密码来获得。

例如：

//连接MySql数据库，用户名和密码都是root

String url = "jdbc:mysql://localhost:3306/test"

String username = "root"

String password = "root"

try{

Connection con =

DriverManager.getConnection(url , username , password )

}catch(SQLException se){

System.out.println("数据库连接失败！")

se.printStackTrace()

}

4、创建一个Statement

•要执行SQL语句，必须获得java.sql.Statement实例，Statement实例分为以下3

种类型：

1、执行静态SQL语句。通常通过Statement实例实现。

2、执行动态SQL语句。通常通过PreparedStatement实例实现。

3、执行数据库存储过程。通常通过CallableStatement实例实现。

具体的实现方式：

Statement stmt = con.createStatement()

PreparedStatement pstmt = con.prepareStatement(sql)

CallableStatement cstmt =

con.prepareCall("{CALL demoSp(? , ?)}")

5、执行SQL语句

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

和execute

1、ResultSet executeQuery(String sqlString)：执行查询数据库的SQL语句

，返回一个结果集（ResultSet）对象。

2、int executeUpdate(String sqlString)：用于执行INSERT、UPDATE或

DELETE语句以及SQL DDL语句，如：CREATE TABLE和DROP TABLE等

3、execute(sqlString):用于执行返回多个结果集、多个更新计数或二者组合的

语句。

具体实现的代码：

ResultSet rs = stmt.executeQuery("SELECT * FROM ...")

int rows = stmt.executeUpdate("INSERT INTO ...")

boolean flag = stmt.execute(String sql)

6、处理结果

两种情况：

1、执行更新返回的是本次 *** 作影响到的记录数。

2、执行查询返回的结果是一个ResultSet对象。

• ResultSet包含符合SQL语句中条件的所有行，并且它通过一套get方法提供了对这些

行中数据的访问。

• 使用结果集（ResultSet）对象的访问方法获取数据：

while(rs.next()){

String name = rs.getString("name")

String pass = rs.getString(1) // 此方法比较高效

}

（列是从左到右编号的，并且从列1开始）

7、关闭JDBC对象

*** 作完成以后要把所有使用的JDBC对象全都关闭，以释放JDBC资源，关闭顺序和声

明顺序相反：

1、关闭记录集

2、关闭声明

3、关闭连接对象

if(rs != null){ // 关闭记录集

try{

rs.close()

}catch(SQLException e){

e.printStackTrace()

}

}

if(stmt != null){ // 关闭声明

try{

stmt.close()

}catch(SQLException e){

e.printStackTrace()

}

}

if(conn != null){ // 关闭连接对象

try{

conn.close()

}catch(SQLException e){

e.printStackTrace()

}

}

  package com.test.db  

  

import java.sql.Connection  

import java.sql.DriverManager  

import java.sql.PreparedStatement  

import java.sql.ResultSet  

import java.sql.SQLException  

/** 

 * @(#)DataBase.java 010/04/22 

 * @author Dudu 

 * EST.All rights reserved 

 */  

public class DataBase {  

    /**定义一个Connection 用来连接数据库*/  

    private Connection conn=null  

    /**连接数据库的URL*/  

    private final String url="jdbc:mysql://localhost/lyvee"  

    /**指定数据的用户名和密码*/  

    private final String username="root"  

    private final String password="123"  

    /**定义一个int记录更新的记录数量*/  

    int count=0  

    /**定义一个结果集 用于放回查询结果*/  

    private ResultSet resultSet=null  

    private PreparedStatement pstmt=null  

    public DataBase(){  

        conn = connectionDB()  

    }  

    /** 

     * 建立数据的连接 

     * @exception SQLException, ClassNotFoundException 

     */  

    @SuppressWarnings("finally")  

    public Connection connectionDB(){  

        try{  

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

            conn=DriverManager.getConnection(url,username,password)  

            System.out.println("连接数据库成功")  

        }catch(Exception e){  

            e.printStackTrace()  

            System.out.println("建立数据库发生错误！")  

        }finally{  

            return conn  

        }  

    }  

    /** 

     * 查询方法 

     * @param sql查询sql语句 

     * @return resultSet 

     */  

    @SuppressWarnings("finally")  

    public ResultSet query(String sql){  

        try {  

            pstmt = conn.prepareStatement(sql)  

            /**查询*/  

            resultSet = pstmt.executeQuery()  

        } catch (SQLException e) {  

            e.printStackTrace()  

        }finally{  

            return resultSet  

        }  

    }  

    /** 

     * 更新数据 

     * @param sql 更新sql语句 

     * @return 

     */  

    public int update(String sql){  

        try {  

            pstmt = conn.prepareStatement(sql)  

            count=pstmt.executeUpdate()  

        } catch (SQLException e) {  

            e.printStackTrace()  

            System.out.println("执行更新出错了")  

        }  

          

        return count  

          

    }  

    /**关闭连接*/  

    public boolean coles(){  

        boolean isColes = false  

        if(resultSet!=null){  

            try {  

                resultSet.close()  

                resultSet=null  

                isColes=true  

            } catch (SQLException e) {  

                isColes=false  

                e.printStackTrace()  

                System.out.println("关闭结果集发生错误")  

            }  

        }  

        if(pstmt!=null){  

            try {  

                pstmt.close()  

                pstmt=null  

                isColes=true  

            } catch (SQLException e) {  

                isColes=false  

                e.printStackTrace()  

                System.out.println("关闭pstmt发生异常")  

            }  

        }  

        if(conn!=null){  

            try{  

                conn.close()  

                conn=null  

                isColes=true  

            }catch (Exception e) {  

                isColes=false  

                e.printStackTrace()  

                System.out.println("关闭conn发生异常")  

            }  

        }  

        return isColes  

    }  

    /** 

     * 测试查询的方法 

     * @throws SQLException 

     */  

    public void testQuery() throws SQLException{  

        resultSet =query("select * from lyvee")  

        if(resultSet.next()){  

            System.out.println(resultSet.getString(1))  

            System.out.println(resultSet.getString(3))  

            System.out.println(resultSet.getString(2))  

        }  

    }  

    public void testUpdate(){  

        count = update("insert into lyvee(lname,lpwd,lsex)values('tanliang','aaa111','sex')")  

        if(count>0){  

            System.out.println("更新成功")  

        }  

    }  

    /** 

     *  

     * @param args 

     * @throws SQLException 

     * @throws ClassNotFoundException 

     */  

    public static void main(String[] args) throws SQLException, ClassNotFoundException {  

        DataBase db = new DataBase()  

        /**调用查询方法*/  

        //db.testQuery()  

        /**调用更新方法*/  

        db.testUpdate()  

        /**调用关闭连接方法*/  

        db.coles()  

          

    }  

}

JDBC连接Access第一种方法:

用下面的代码试试 （强烈建议也是only可以建议的方法）

con = DriverManager.getConnection("jdbc:odbc:Driver={MicroSoft Access Driver (*.mdb)}DBQ=C:/data/Access/test1.mdb","dba","sql")

后面的代码一样。这样你就可以访问access数据库了。

JDBC连接Access第二种方法:

用sun的jdbcodbc桥，数据源（个人主页不适用）

JDBC连接Access第三种方法:

对于设置与Windows下的JSP服务器，且系统较小时，使用Access是一个比较好的选择，但是要使用Access数据库一般要通过数据源。这里提供一种不用使用数据源用Java直接连接数据源的方法。例子程序如下：

import java.sql.*public class Access { public static void main(String args[]) { try { String strurl="jdbc:odbc:driver={Microsoft Access Driver (*.mdb)}DBQ=books.mdb"Class.forName("sun.jdbc.odbc.JdbcOdbcDriver")Connection conn=DriverManager.getConnection(strurl) Statement stmt=conn.createStatement()ResultSet rs=stmt.executeQuery("select * from books")if(rs.next()) { System.out.println(rs.getString("简介"))} }catch(Exception e) { System.out.println(e)} } }

可以看到只要在driver后面加上ODBC驱动即可不用设置数据源，这种方法对其他小型数据库（如forpro）应该也适用。

---