JDBC知识点

JDBC的基本原理

JDBC是Java操作数据库的技术规范。他实际上定义了一组标准的操作数据库的接口。为了能让Java操作数据库，必须要有实现了JDBC这些接口的类，不同的数据库厂商为了让Java语言能操作自己的数据库，都提供了对JDBC接口的实现--这些实现了JDBC接口的类打成一个jar包，就是我们平时看到的数据库驱动。

 

 

1、JDBC

JDBC（Java Data Base Connectivity,java数据库连接），由一些接口和类构成的API。J2SE的一部分，由java.sql,javax.sql包组成。

 

2、JDBC驱动

JDBC驱动是JDBC API接口的具体实现，不同数据库的实现细节不同。

驱动类型(四种类型)，一般优先使用纯Java的驱动，已获得更好的效率。

 

3、JDBC操作数据库的一般步骤

注册驱动 (只做一次)

建立连接(Connection)

创建执行SQL的语句(Statement)

执行语句

处理执行结果(ResultSet)

释放资源

 

4、注册JDBC驱动

有三种方式：

Class.forName(“com.mysql.jdbc.Driver”);

 推荐这种方式，不会对具体的驱动类产生依赖。

DriverManager.registerDriver(com.mysql.jdbc.Driver);

 会造成DriverManager中产生两个一样的驱动，并会对具体的驱动类产生依赖。

System.setProperty(“jdbc.drivers”, “driver1:driver2”);

 虽然不会对具体的驱动类产生依赖；但注册不太方便，所以很少使用。

 

DriverManager是一个驱动管理器，内部有一个驱动注册表（Map结构），可以向其注册多个JDBC驱动。

 

 

5、建立Connection

Connection conn = DriverManager.getConnection(url, user, password);

url格式：JDBC:子协议:子名称//主机名:端口/数据库名？属性名=属性值&…

User,password可以用“属性名=属性值”方式告诉数据库；

其他参数如：useUnicode=true&characterEncoding=GBK。

 

6、建立Statement、PreparedStatement

Statement是一个SQL执行器，可以用来执行一个静态的SQL语句。

Statement st = conn.createStatement();

st.executeQuery(sql);

 

PreparedStatement是一个与定义的SQL执行器，一般较Statement有防止SQL注入的功能，还有较好的执行效率。

String sql = "select * from table_name where col_name=?";

PreparedStatement ps = conn.preparedStatement(sql);

ps.setString(1, "col_value");

ps.executeQuery();

 

在数据库连接没有关闭的情况下，数据库和驱动可以对PreperedStatement进行优化，PreperedStatement对象可以被重用，从而避免频繁编译SQL。

 

7、处理ResultSet

ResultSet表示一个查询结果集。

ResultSet rs = statement.executeQuery(sql);

While(rs.next()){

 rs.getString(“col_name”);

 rs.getInt(“col_name”);

 //…

}

 

8、释放资源

释放资源的顺序是ResultSet, Statement,Connection；

Connection在使用完成后，必须关闭，ResultSet, Statement无所谓，只要Connection关闭了，它们也会被自动关闭（但资源不是立即被释放）。

Connection的使用原则是尽量晚创建，尽量早的释放。

在关闭资源异常的情况下，应该将资源赋null值，以确保资源最大可能的被释放掉。

 

9、数据类型

几种特殊且比较常用的类型

1.DATA,TIME,TIMESTAMP date,time,datetime

存：ps.setDate(i,d); ps.setTime(i,t); ps.setTimestamp(i, ts);

取：rs.getDate(i); rs.getTime(i); rs.getTimestamp(i);

2.CLOB  text

存：ps.setCharacterStream(index, reader, length);

    ps.setString(i, s);

取：reader = rs. getCharacterStream(i);

    reader = rs.getClob(i).getCharacterStream();

    string = rs.getString(i);

3.BLOB  blob

存：ps.setBinaryStream(i, inputStream, length);

取：rs.getBinaryStream(i);

    rs.getBlob(i).getBinaryStream();

 

10、事物

原子性(atomicity)：组成事务处理的语句形成了一个逻辑单元，不能只执行其中的一部分。

一致性(consistency)：在事务处理执行前后，数据库是一致的(两个账户要么都变，或者都不变)。

隔离性(isolcation)：一个事务处理对另一个事务处理没有影响。

持续性(durability)：事务处理的效果能够被永久保存下来 。

 

connection.setAutoCommit(false);//打开事务。

connection.commit();//提交事务。

connection.rollback();//回滚事务。

 

11、隔离级别

隔离级别是控制并发访问数据的安全话题。

connection.setTransactionIsolation(Connection.TRANSACTION_READ_COMMITTED);

读未提交（Read uncommitted）

读已提交（Read committed）

可重复读（Repeatable read）

可串行化（Serializable ）

 

12、执行存储过程

CallableStatement（从PreperedStatement扩展来）

cs = connection.prepareCall(“{call psname(?,?,?)}”);

cs.registerOutParameter(index, Types.INTEGER);

cs.setXXX(i, xxxx);

cs.executeUpdate();

int id=cs.getInt(index);    

 

 

常用的连接方式：

1、Oracle8/8i/9i数据库（thin模式）

 

    Class.forName("oracle.jdbc.driver.OracleDriver").newInstance();

    String url="jdbc:oracle:thin:@localhost:1521:orcl";

    //orcl为数据库的SID

    String user="test";

    String password="test";

    Connection conn= DriverManager.getConnection(url,user,password);

 

2、DB2数据库

 

    Class.forName("com.ibm.db2.jdbc.app.DB2Driver ").newInstance();

    String url="jdbc:db2://localhost:5000/sample";

    //sample为你的数据库名

    String user="admin";

    String password="";

    Connection conn= DriverManager.getConnection(url,user,password);

 

3、Sql Server7.0/2000数据库

 

    Class.forName("com.microsoft.jdbc.sqlserver.SQLServerDriver").newInstance();

    String url="jdbc:microsoft:sqlserver://localhost:1433;DatabaseName=mydb";

    //mydb为数据库

    String user="sa";

    String password="";

    Connection conn= DriverManager.getConnection(url,user,password);

 

4、Sybase数据库

 

    Class.forName("com.sybase.jdbc.SybDriver").newInstance();

    String url =" jdbc:sybase:Tds:localhost:5007/myDB";

    //myDB为你的数据库名

    Properties sysProps = System.getProperties();

    SysProps.put("user","userid");

    SysProps.put("password","user_password");

    Connection conn= DriverManager.getConnection(url, SysProps);

 

5、Informix数据库

 

    Class.forName("com.informix.jdbc.IfxDriver").newInstance();

    String url =

    "jdbc:informix-sqli://123.45.67.89:1533/myDB:INFORMIXSERVER=myserver;

    user=testuser;password=testpassword";

    //myDB为数据库名

    Connection conn= DriverManager.getConnection(url);

 

6、MySQL数据库

 

    Class.forName("org.gjt.mm.mysql.Driver").newInstance();

    String url ="jdbc:mysql://localhost/myDB?user=soft&password=soft1234&useUnicod

    e=true&characterEncoding=8859_1"

    //myDB为数据库名

    Connection conn= DriverManager.getConnection(url);

 

7、PostgreSQL数据库

 

    Class.forName("org.postgresql.Driver").newInstance();

    String url ="jdbc:postgresql://localhost/myDB"

    //myDB为数据库名

    String user="myuser";

    String password="mypassword";

    Connection conn= DriverManager.getConnection(url,user,password);

 

 

注册Jdbc驱动程序的三种方式：

1、比较常用

try{

       Class.forName("com.mysql.jdbc.Driver");//加载数据库驱动

       String url="jdbc:mysql://localhost:3306/databasename";//数据库连接子协议

       Connection conn=DriverManager.getConnection(url,"username","password");

       Statement stmt=conn.createStatement();

       ResultSet rs=stmt.executeQuery("select * from tablename");

       while(rs.next()){//不断指向下一条记录

            System.out.println("DeptNo:"+rs.getInt(1));

            System.out.println("\tDeptName:"+rs.getString(2));

            System.out.println("\tLOC:"+rs.getString(3));

}         

    rs.close();

    stmt.close();

    conn.close();

}catch(ClassNotFoundException e){

   System.out.println("找不到指定的驱动程序类！");

}catch(SQLException e){

    e.printStackTrace();

}

 

 

2、通过系统的属性设置

try{

       System.setProperty("jdbc.driver","com.mysql.jdbc.Driver");//系统属性指定数据库驱动

       String url="jdbc:mysql://localhost:3306/databasename";//数据库连接子协议

       Connection conn=DriverManager.getConnection(url,"username","password");

       Statement stmt=conn.createStatement();

       ResultSet rs=stmt.executeQuery("select * from tablename");

       while(rs.next()){//不断指向下一条记录

            System.out.println("DeptNo:"+rs.getInt(1));

            System.out.println("\tDeptName:"+rs.getString(2));

            System.out.println("\tLOC:"+rs.getString(3));

}         

    rs.close();

    stmt.close();

    conn.close();

}catch(SQLException e){

    e.printStackTrace();

}

 

<!--[if !supportLineBreakNewLine]-->

<!--[endif]-->

3、看起来比较直观的一种方式，注册相应的db的jdbc驱动，3在编译时需要导入对应的lib

try{

       new com.mysql.jdbc.Driver();//创建driver对象，加载数据库驱动

       String url="jdbc:mysql://localhost:3306/databasename";//数据库连接子协议

       Connection conn=DriverManager.getConnection(url,"username","password");

       Statement stmt=conn.createStatement();

       ResultSet rs=stmt.executeQuery("select * from tablename");

       while(rs.next()){//不断指向下一条记录

            System.out.println("DeptNo:"+rs.getInt(1));

            System.out.println("\tDeptName:"+rs.getString(2));

            System.out.println("\tLOC:"+rs.getString(3));

}         

    rs.close();

    stmt.close();

    conn.close();

}catch(SQLException e){

    e.printStackTrace();

}