Java之美_JDBC详解
什么是JDBC?
Java语言访问数据库的一种规范,是一套API
JDBC(JavaDatabaseConnectivity)API，即Java数据库编程接口，是一组标准的Java语言中的接口和类，使用这些接口和类，Java客户端程序可以访问各种不同类型的数据库。比如建立数据库连接、执行SQL语句进行数据的存取操作。
JDBC规范采用接口和实现分离的思想设计了Java数据库编程的框架。接口包含在java.sql及javax.sql包中，其中java.sql属于JavaSE，javax.sql属于JavaEE。这些接口的实现类叫做数据库驱动程序，由数据库的厂商或其它的厂商或个人提供。
为了使客户端程序独立于特定的数据库驱动程序，JDBC规范建议开发者使用基于接口的编程方式，即尽量使应用仅依赖java.sql及javax.sql中的接口和类。
JDBC驱动程序:
什么是JDBC驱动程序?
这些是各个数据库厂家根据JDBC的规范制作的JDBC实现类
JDBC驱动程序的四种类型:
1.第一种类型的驱动程序的实现是通过将JDBC的调用全部委托给其它编程接口来实现的，比如ODBC。这种类型的驱动程序需要安装本地代码库，即依赖于本地的程序，所以便携性较差。比如JDBC-ODBC桥驱动程序
2.第二种类型的驱动程序的实现是部分基于Java语言的。即该驱动程序一部分是用Java语言编写，其它部分委托本地的数据库的客户端代码来实现。同类型1的驱动一样，该类型的驱动程序也依赖本地的程序，所以便携性较差
3.第三种类型的驱动程序的实现是全部基于JAVA语言的。该类型的驱动程序通常由某个中间件服务器提供，这样客户端程序可以使用数据库无关的协议和中间件服务器进行通信，中间件服务器再将客户端的JDBC调用转发给数据库进行处理
4.第四种类型的驱动程序的实现是全部基于JAVA语言的。该类型的驱动程序中包含了特定数据库的访问协议，使得客户端可以直接和数据库进行通信
JDBC类结构:
DriverManager
DriverDriver
ConnectionConnection
StatementStatement
ResultsetResultset
DriverManager:这个是一个实现类,它是一个工厂类,用来生产Driver对象的
这个类的结构设计模式为工厂方法
Driver:这是驱动程序对象的接口,它指向一个实实在在的数据库驱动程序对象,那么这个数据库驱动程序对象是从哪里来的呢?
DriverManager工厂中有个方法:getDriver(StringURL),通过这个方法可以得到驱动程序对象,这个方法是在各个数据库厂商按JDBC规范设计的数据库驱动程序包里的类中静态实现的,也就是在静态块中
Connection:这个接口可以制向一个数据库连接对象,那么如何得到这个连接对象呢?
是通过DriverManager工厂中的getConnection(StringURL)方法得到的
Statement:用于执行静态的SQL语句的接口,通过Connection中的createStatement方法得到的
Resultset:用于指向结果集对象的接口,结果集对象是通过Statement中的execute等方法得到的
JAVA使用JDBC访问数据库的步骤:
1.得到数据库驱动程序
2.创建数据库连接
3.执行SQL语句
4.得到结果集
5.对结果集做相应的处理(增,删,改,查)
6.关闭资源:这里释放的是DB中的资源
设置classpath:
1.在java文件中起的包名一定要是工程基目录下的子目录,classpath:基目录
2..jar包,需要将这个.jar包的路径包括这个文件的全名添加到classpath中来
Oracle连接字符串的书写格式:
“oracle:jdbc:thin:@ip:1521:数据库名”,”数据库用户名”,”数据库密码”
简单的例子:
package moudule1.first;
import java.sql.*;
public class FirstJdbc
{
public static void main(String[] args)
{
String sql="select * from yuchen_user";
Connection con=null;
Statement st=null;
ResultSet rs=null;
try
{
Class.forName("oracle.jdbc.driver.OracleDriver");
con=DriverManager.getConnection("jdbc:oracle:thin:@127.0.0.1:1521:name", "scott","tiger");
st=con.createStatement();
rs=st.executeQuery(sql);
while(rs.next())
{
System.out.println(rs.getInt("id"));
System.out.println(rs.getString("name"));
}
}catch(Exception e)
{
e.printStackTrace();
}finally
{
try
{
con.close();
}catch(Exception e)
{}
try
{
st.close();
}catch(Exception e)
{
}
try
{
rs.close();
}catch(Exception e)
{
}
}
}
}常用数据库的驱动程序及JDBCURL:
Oracle数据库:
驱动程序包名：ojdbc14.jar
驱动类的名字：oracle.jdbc.driver.OracleDriver
JDBCURL：jdbc:oracle:thin:@dbip:port:databasename
说明：驱动程序包名有可能会变
JDBCURL中黑色字体部分必须原封不动的保留，为该驱动识别的URL格式。红色字体部分需要根据数据库的安装情况填写。其中各个部分含义如下：
dbip–为数据库服务器的IP地址，如果是本地可写：localhost或127.0.0.1。
port–为数据库的监听端口，需要看安装时的配置，缺省为1521。
databasename–为数据库的SID，通常为全局数据库的名字。
举例如果要访问本地的数据库allandb，端口1521，那么URL写法如下：
jdbc:oracle:thin:@localhost:1521:allandb下载地址如下:
http://www.oracle.com/technology/software/tech/java/sqlj_jdbc/index.html
SQLServer数据库
驱动程序包名：msbase.jarmssqlserver.jarmsutil.jar
驱动类的名字：com.microsoft.jdbc.sqlserver.SQLServerDriver
JDBCURL：jdbc:microsoft:sqlserver://dbip:port;DatabaseName=databasename
说明：驱动程序包名有可能会变
JDBCURL中黑色字体部分必须原封不动的保留，为该驱动识别的URL格式。红色字体部需要根据数据库的安装情况填写。其中各个部分含义如下：
dbip–为数据库服务器的IP地址，如果是本地可写：localhost或127.0.0.1。
port–为数据库的监听端口，需要看安装时的配置，缺省为1433。
databasename–数据库的名字。
举例如果要访问本地的数据库allandb，端口1433，那么URL写法如下：
jdbc:microsoft:sqlserver:@localhost:1433;DatabaseName=allandb
下载地址：http://www.microsoft.com/downloads/details.aspx
MySQL数据库
驱动程序包名：mysql-connector-java-3.1.11-bin.jar
驱动类的名字：com.mysql.jdbc.Driver
JDBCURL：jdbc:mysql://dbip:port/databasename
说明：驱动程序包名有可能会变
JDBCURL中黑色字体部分必须原封不动的保留，为该驱动识别的URL格式。红色字体部需要根据数据库的安装情况填写。其中各个部分含义如下：
dbip–为数据库服务器的IP地址，如果是本地可写：localhost或127.0.0.1。
port–为数据库的监听端口，需要看安装时的配置，缺省为3306。
databasename–数据库的名字。
举例如果要访问本地的数据库allandb，端口1433，那么URL写法如下：
jdbc:mysql://localhost:3306/allandb
下载地址：http://dev.mysql.com/downloads/connector/j/
Access数据库
驱动程序包名：该驱动程序包含在JavaSE中，不需要额外安装。
驱动类的名字：sun.jdbc.odbc.JdbcOdbcDriver
JDBCURL：jdbc:odbc:datasourcename
说明：该驱动只能工作在Windows系统中，首先需要在操作系统中建立一个可以访问Access数据库的本地数据源(ODBC)，如果名字为allandb，那么URL写法如下：
jdbc:odbc:allandb
PreparedStatement接口:
预编译的sql语句对象
作用:解决了书写sql语句时一些特殊的字符与sql保留字符冲突的问题,非常方便
/**
*知识点:
*PreparedStatement接口及方法的使用
*程序目标:
*java文件:
*PreparedInsert.java:连接数据库,插入一条数据
*JdbcUtil.java:实现一个工具类,功能:1.连接数据库2.关闭资源
*/
package moudule1.preparedstatement;
import java.sql.*;
import moudule1.com.*;
public class PreparedInsert
{
public static void main(String[] args)
{
String sql="insert into yuchen_user (id,name) values (?,?)";
System.out.println(sql);
Connection con=null;
PreparedStatement ps=null;
try{
con=JdbcUtil.getConnection();
ps=con.prepareStatement(sql);
ps.setInt(1,2);
ps.setString(2,"zhangsan");
ps.executeUpdate();
ps.setInt(1,3);
ps.setString(2,"lisi");
ps.executeUpdate();
}catch(Exception e){
e.printStackTrace();
}finally{
JdbcUtil.close(con,ps);
}
}
}
package moudule1.com;
import java.sql.*;
public class JdbcUtil{
public static Connection getConnection() throws Exception{
Class.forName("oracle.jdbc.driver.OracleDriver");
return DriverManager.getConnection("jdbc:oracle:thin:@127.0.0.1:1521:name", "scott","tiger");
}
public static void close(Connection con,Statement st){
close(con);
close(st);
}
public static void close(Connection con,Statement st,ResultSet rs){
close(con,st);
close(rs);
}
public static void close(Connection con){
try{
con.close();
}catch(Exception e){
}
}
public static void close(Statement st){
try{
st.close();
}catch(Exception e){
}
}
public static void close(ResultSet rs){
try{
rs.close();
}catch(Exception e){
}
}
}数据库的增删改查的例子:
/**
*知识点:
*JDBC+SQL+ORACLE
*程序目标:
*UserDao.java:实现了数据库的增删改查
*JdbcUtil.java:工具类,有连库和关闭资源的方法
*/
package moudule1.idus;
import java.sql.*;
import moudule1.com.*;
public class UserDao{
private String sql;
private Connection con;
private Statement st;
private ResultSet rs;
public UserDao(){
sql=null;
con=null;
st=null;
rs=null;
}
public void insert(){
sql="insert into yuchen_user (id,name) values(";
sql+="4,'zhouwu')";
System.out.println(sql);
try{
con=JdbcUtil.getConnection();
st=con.createStatement();
st.executeUpdate(sql);
}catch(Exception e){
e.printStackTrace();
}finally{
JdbcUtil.close(con,st);
}
}
public void delete(){
sql="delete from yuchen_user where id=2";
System.out.println(sql);
try{
con=JdbcUtil.getConnection();
st=con.createStatement();
st.executeUpdate(sql);
}catch(Exception e){
e.printStackTrace();
}finally{
JdbcUtil.close(con,st);
}
}
public void update(){
sql="update yuchen_user set name='liumang' where id=1";
System.out.println(sql);
try{
con=JdbcUtil.getConnection();
st=con.createStatement();
st.executeUpdate(sql);
}catch(Exception e){
e.printStackTrace();
}finally{
JdbcUtil.close(con,st);
}
}
public void select(){
sql="select * from yuchen_user";
System.out.println(sql);
try{
con=JdbcUtil.getConnection();
st=con.createStatement();
rs=st.executeQuery(sql);
while(rs.next()){
System.out.println(rs.getInt(1));
System.out.println(rs.getString(2));
}
}catch(Exception e){
e.printStackTrace();
}finally{
JdbcUtil.close(con,st,rs);
}
}
public static void main(String[] args){
UserDao ud=new UserDao();
ud.select();
ud.insert();
ud.select();
ud.update();
ud.select();
ud.delete();
ud.select();
}
}一些常用的方法:
/**
*知识点:
*execute方法,getResultSet(),getUpdateCount()
*程序目标:
*JdbcUtil.java:工具类,连接数据库,关闭资源
*sqlExecutor.java:命令行参数输入sql语句,并执行该语句
*/
package moudule1.fangfa;
import java.sql.*;
import moudule1.com.*;
public class sqlExecutor{
public static void main(String[] args){
Connection con=null;
Statement st=null;
try{
con=JdbcUtil.getConnection();
st=con.createStatement();
boolean str=st.execute(args[0]);
if(str){
ResultSet rs=st.getResultSet();
while(rs.next()){
System.out.println(rs.getInt("id")+":"+rs.getString("name"));
}
rs.close();
}else{
int row=st.getUpdateCount();
System.out.println(row);
}
}catch(Exception e){
e.printStackTrace();
}finally{
JdbcUtil.close(con,st);
}
}
}2.补充JDBC连接MySQL
加载及注册JDBC驱动程序
Class.forName("com.mysql.jdbc.Driver");
Class.forName("com.mysql.jdbc.Driver").newInstance();
JDBCURL定义驱动程序与数据源之间的连接
标准语法：
<protocol（主要通讯协议）>:<subprotocol（次要通讯协议，即驱动程序名称）>:<datasourceidentifier（数据源）>
MySQL的JDBCURL格式：
jdbc:mysql//[hostname][:port]/[dbname][?param1=value1][¶m2=value2]….
示例：jdbc:mysql://localhost:3306/sample_db?user=root&password=your_password
常见参数：
user用户名
password密码
autoReconnect联机失败，是否重新联机（true/false）
maxReconnect尝试重新联机次数
initialTimeout尝试重新联机间隔
maxRows传回最大行数
useUnicode是否使用Unicode字体编码（true/false）
characterEncoding何种编码（GB2312/UTF-8/…）
relaxAutocommit是否自动提交（true/false）
capitalizeTypeNames数据定义的名称以大写表示
建立连接对象
Stringurl="jdbc:mysql://localhost:3306/sample_db?user=root&password=your_password";
Connectioncon=DriverManager.getConnection(url);
建立SQL陈述式对象（StatementObject）
Statementstmt=con.createStatement()；
执行SQL语句
executeQuery()
Stringquery="select*fromtest";
ResultSetrs=stmt.executeQuery(query);
结果集ResultSet
while(rs.next())
{rs.getString(1);rs.getInt(2);}
executeUpdate()
Stringupd="insertintotest(id,name)values(1001,xuzhaori)";
intcon=stmt.executeUpdate(upd);
execute()
示例：
try{}
catch(SQLExceptionsqle)
{
}
finally
{
}
Java类型和SQL类型技术手册P421
PreparedStatement（预编语句）
PreparedStatementstmt=conn.prepareStatement("insertintotest(id,name)values(?,?)");
stmt.setInt(1,id);
stmt.setString(2,name);
注：一旦设定语句的参数值后，就可以多次执行改语句，直到调用clearParameters（）方法将他清除为止
CallableStatement（预储程序）技术手册P430
JDBC2.0使用
ResultSet对象中的光标上下自由移动
Statementstmt=con.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_READ_ONLY);
ResultSetrs=stmt.executeQuery("select*fromtest");
publicStatementcreateStatement(intresultSetType,intresultSetConcuttency)throwsSQLException
resultSetType
TYPE_FORWARD_ONLY只能使用next（）方法。
TYPE_SCROLL_SENSITIVE可以上下移动，可以取得改变后的值。
TYPE_SCROLL_INSENSITIVE可以上下移动。
resultSetConcuttency
CONCUR_READ_ONLY只读
CONCUR_UPDATABLEResultSet对象可以执行数据库的新增、修改、和移除
直接使用ResultSet对象执行更新数据
新增数据
Statementstmt＝con.createStatement（ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_PUDATABLE）;
ResultSetuprs=stmt.executeQuery("select*fromtest");
uprs.moveToInsertRow();
uprs.updateInt(1,1001);
uprs.updateString(2,"许召日");
uprs.insertRow;
更新数据
Statementstmt＝con.createStatement（ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_PUDATABLE）;
ResultSetuprs=stmt.executeQuery("select*fromtest");
uprs.last();
uprs.updateString("name","xuzhaori");
uprs.updateRow;
删除数据
Statementstmt＝con.createStatement（ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_PUDATABLE）;
ResultSetuprs=stmt.executeQuery("select*fromtest");
uprs.absolute(4);
uprs.deleteRow();
批处理
con.setAutoCommit(false);关闭自动认可模式
Statementstmt=con.createStatement();
int[]rows;
stmt.addBatch("insertintotestvalues(1001,xuzhaori)");
stmt.addBatch("insertintotestvalues(1002,xuyalin)");
rows=stmt.executeBatch();
con.commit();没有任何错误，执行批处理stmt.executeBatch();
JNDI-数据源（DataSource）与连接池（ConnectionPool）
Tomcat的JDBC数据源设置技术手册P439
连接池工具－ProxoolVar0.8.3技术手册P446
设置web.xml
<?xml version="1.0" encoding="ISO-8859-1"?> <!--<?xml version="1.0" encoding="GB2312"?>--> <web-app xmlns="http://java.sun.com/xml/ns/j2ee" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://java.sun.com/xml/ns/j2ee/web-app_2_4.xsd" version="2.4"> …. <servlet> <servlet-name>ServletConfigurator</servlet-name> <servlet-class>org.logicalcobwebs.proxool.configuration.ServletConfigurator</servlet-class> <init-param> <param-name>propertyFile</param-name> <param-value>WEB-INF/classes/Proxool.properties</param-value> </init-param> <load-on-startup>1</load-on-startup> </servlet> 后端统计端口添加下列 <servlet> <servlet-name>Admin</servlet-name> <servlet-class>org.logicalcobwebs.proxool.admin.servlet.AdminServlet</servlet-class> </servlet> <servlet-mapping> <servlet-name>Admin</servlet-name> <url-pattern>/Admin</url-pattern> </servlet-mapping> …. </web-app>
配置Proxool.properties
jdbc-0.proxool.alias=JSPBook
jdbc-0.proxool.driver-class=com.mysql.jdbc.Driver
jdbc-0.proxool.driver-url=jdbc:mysql://localhost:3306/sample_db?user=root&password=browser&useUnicode=true&characterEncoding=UTF-8
jdbc-0.proxool.maximum-connection-count=10
jdbc-0.proxool.prototype-count=4
jdbc-0.proxool.house-keeping-test-sql=selectCURRENT_DATE
jdbc-0.proxool.verbose=true
jdbc-0.proxool.statistics=10s,1m,1d后端统计接口添加此行
jdbc-0.proxool.statistics-log-level=DEBUG
使用Proxool连接池
Connectioncon=DriverManager.getConnection("proxool.JSPBook");
Statementstmt=con.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_UPDATABLE);
Stringquery="SELECT*FROMemployee";
ResultSetrs=stmt.executeQuery(query);