1)连接Oracle 8/8i/9i/10g/11g（thin模式）Class.forName("oracle.JDBC.driver.OracleDriver").newInstance();String url="JDBC:oracle:thin:@localhost:1521:orcl"       //orcl为Oracle数据库的SIDString user="test";String password="test";Connection con=DriverManager.getConnection(url,user,password);2)连接DB2数据库Class.forName("com.ibm.db2.jcc.DB2Driver");String url="JDBC:db2://localhost:5000/testDb";String user="test"; String password="test";Connection con=DriverManager.getConnection(url,user,password);3)连接MySQL数据库Class.forName("com.mysql.jdbc.Driver");String url="JDBC:mysql://localhost:8080/testDB";String user="test"; String password="test";Connection con=DriverManager.getConnection(url,user,password);4)连接SQL Server2000数据库Class.forName("com.microsoft.JDBC.sqlserver.SQLServerDriver");String url="JDBC:microsoft:sqlserver://localhost:1433;DatabaseName=testDb";String user="test"; String password="test";Connection con=DriverManager.getConnection(url,user,password);5)连接PostgreSQL数据库Class.forName("org.postgresql.Driver");String url="JDBC:postgresql://localhost/testDb";String user="test"; String password="test";Connection con=DriverManager.getConnection(url,user,password);6)连接Access数据库Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");String url="JDBC:odbc:Driver={Microsoft Access Driver (*.mdb)};DBQ="+application.getRealPath("/Data/testDb/mdb");Connection conn=DriverManager.getConnection(url,"","");7连接Sybase数据库Class.forName("com.sybase.JDBC.SybDriver");String url="JDBC:sybase:Tds:localhost:5007/testDb";Properties pro=System.getProperties();pro.put("user","userId");pro.put("password","user_password");Connection con=DriverManager.getConnection(url,pro);8连接informix数据库Class.forName("com.informix.JDBC.ifxDriver");String url="JDBC:informix-sqli:localhost:1533/testDb:INFORMIXSERVER=myserver"user=testUser;password=testpassword"; Connection con=DriverManager.getConnection(url);

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() ;            }             }  

什么是JDBC?Java语言访问数据库的一种规范,是一套APIJDBC (Java Database Connectivity) 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 Driver                     Driver Connection                 Connection Statement                  Statement Resultset                  Resultset DriverManager:这个是一个实现类,它是一个工厂类,用来生产Driver对象的这个类的结构设计模式为工厂方法Driver:这是驱动程序对象的接口,它指向一个实实在在的数据库驱动程序对象,那么这个数据库驱动程序对象是从哪里来的呢?DriverManager工厂中有个方法:getDriver(String URL),通过这个方法可以得到驱动程序对象,这个方法是在各个数据库厂商按JDBC规范设计的数据库驱动程序包里的类中静态实现的,也就是在静态块中Connection:这个接口可以制向一个数据库连接对象,那么如何得到这个连接对象呢?是通过DriverManager工厂中的getConnection(String URL)方法得到的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)                 {                 }                            }                       }     }  常用数据库的驱动程序及JDBC URL:Oracle数据库:驱动程序包名：ojdbc14.jar驱动类的名字：oracle.jdbc.driver.OracleDriver  JDBC URL：jdbc:oracle:thin:@dbip:port:databasename 说明：驱动程序包名有可能会变       JDBC URL中黑色字体部分必须原封不动的保留，为该驱动识别的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

SQL Server数据库   驱动程序包名：msbase.jar mssqlserver.jar msutil.jar   驱动类的名字：com.microsoft.jdbc.sqlserver.SQLServerDriver   JDBC URL：jdbc:microsoft:sqlserver://dbip:port;DatabaseName=databasename   说明：驱动程序包名有可能会变        JDBC URL中黑色字体部分必须原封不动的保留，为该驱动识别的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   JDBC URL：jdbc:mysql://dbip:port/databasename   说明：驱动程序包名有可能会变        JDBC URL中黑色字体部分必须原封不动的保留，为该驱动识别的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   JDBC URL：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();JDBC URL 定义驱动程序与数据源之间的连接标准语法：<protocol（主要通讯协议）>:<subprotocol（次要通讯协议，即驱动程序名称）>:<data source identifier（数据源）>MySQL的JDBC URL格式：jdbc:mysql//[hostname][:port]/[dbname][?param1=value1][&param2=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        数据定义的名称以大写表示建立连接对象String url="jdbc:mysql://localhost:3306/sample_db?user=root&password=your_password";Connection con = DriverManager.getConnection(url);建立SQL陈述式对象（Statement Object）Statement stmt = con.createStatement()；执行SQL语句executeQuery()String query = "select * from test";ResultSet rs=stmt.executeQuery(query);结果集ResultSetwhile(rs.next()){rs.getString(1);rs.getInt(2);}executeUpdate()String upd="insert into test (id,name) values(1001,xuzhaori)";int con=stmt.executeUpdate(upd);execute()示例：try{}catch(SQLException sqle){}finally{} Java类型和SQL类型 技术手册P421PreparedStatement（预编语句）PreparedStatement stmt = conn.prepareStatement("insert into test(id,name)values(?,?)");stmt.setInt(1,id);stmt.setString(2,name);注：一旦设定语句的参数值后，就可以多次执行改语句，直到调用clearParameters（）方法将他清除为止CallableStatement（预储程序）技术手册P430JDBC2.0使用ResultSet对象中的光标上下自由移动Statement stmt = con.createStatement (ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_READ_ONLY);ResultSet rs=stmt.executeQuery("select * from test"); public Statement createStatement(int resultSetType,int resultSetConcuttency) throws SQLException resultSetTypeTYPE_FORWARD_ONLY            只能使用next（）方法。TYPE_SCROLL_SENSITIVE        可以上下移动，可以取得改变后的值。TYPE_SCROLL_INSENSITIVE      可以上下移动。resultSetConcuttencyCONCUR_READ_ONLY        只读CONCUR_UPDATABLE        ResultSet对象可以执行数据库的新增、修改、和移除 直接使用ResultSet对象执行更新数据新增数据Statement stmt＝con.createStatement（ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_PUDATABLE）;ResultSet uprs=stmt.executeQuery("select * from test");uprs.moveToInsertRow();uprs.updateInt(1,1001);uprs.updateString(2,"许召日");uprs.insertRow;更新数据Statement stmt＝con.createStatement（ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_PUDATABLE）;ResultSet uprs=stmt.executeQuery("select * from test");uprs.last();uprs.updateString("name","xuzhaori");uprs.updateRow;删除数据Statement stmt＝con.createStatement（ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_PUDATABLE）;ResultSet uprs=stmt.executeQuery("select * from test");uprs.absolute(4);uprs.deleteRow(); 批处理con.setAutoCommit(false);  关闭自动认可模式Statement stmt=con.createStatement();int[] rows;stmt.addBatch("insert into test values(1001,xuzhaori)");stmt.addBatch("insert into test values(1002,xuyalin)");rows=stmt.executeBatch();con.commit();  没有任何错误，执行批处理stmt.executeBatch(); JNDI-数据源（Data Source）与连接池（Connection Pool）Tomcat的JDBC数据源设置  技术手册P439连接池工具－Proxool Var 0.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.propertiesjdbc-0.proxool.alias=JSPBookjdbc-0.proxool.driver-class=com.mysql.jdbc.Driverjdbc-0.proxool.driver-url=jdbc:mysql://localhost:3306/sample_db?user=root&password=browser&useUnicode=true&characterEncoding=UTF-8jdbc-0.proxool.maximum-connection-count=10jdbc-0.proxool.prototype-count=4jdbc-0.proxool.house-keeping-test-sql=select CURRENT_DATEjdbc-0.proxool.verbose=truejdbc-0.proxool.statistics=10s,1m,1d    后端统计接口添加此行jdbc-0.proxool.statistics-log-level=DEBUG使用Proxool连接池Connection con = DriverManager.getConnection("proxool.JSPBook");Statement stmt = con.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_UPDATABLE);String query = "SELECT * FROM employee";ResultSet rs = stmt.executeQuery(query);

以下是使用事务提交和回滚描述的例子。基于对环境和数据库安装在前面的章节中做此示例代码已学习过。复制过去下面的例子中JDBCExample.java，编译并运行，如下所示：//STEP 1. Import required packagesimport java.sql.*;public class JDBCExample {   // JDBC driver name and database URL   static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";     static final String DB_URL = "jdbc:mysql://localhost/EMP";   //  Database credentials   static final String USER = "username";   static final String PASS = "password";    public static void main(String[] args) {   Connection conn = null;   Statement stmt = null;   try{      //STEP 2: Register JDBC driver      Class.forName("com.mysql.jdbc.Driver");      //STEP 3: Open a connection      System.out.println("Connecting to database...");      conn = DriverManager.getConnection(DB_URL,USER,PASS);      //STEP 4: Set auto commit as false.      conn.setAutoCommit(false);      //STEP 5: Execute a query to create statment with      // required arguments for RS example.      System.out.println("Creating statement...");      stmt = conn.createStatement(                           ResultSet.TYPE_SCROLL_INSENSITIVE,                           ResultSet.CONCUR_UPDATABLE);           //STEP 6: INSERT a row into Employees table      System.out.println("Inserting one row....");      String SQL = "INSERT INTO Employees " +                    "VALUES (106, 20, ‘Rita‘, ‘Tez‘)";      stmt.executeUpdate(SQL);        //STEP 7: INSERT one more row into Employees table      SQL = "INSERT INTO Employees " +                    "VALUES (107, 22, ‘Sita‘, ‘Singh‘)";      stmt.executeUpdate(SQL);      //STEP 8: Commit data here.      System.out.println("Commiting data here....");      conn.commit();            //STEP 9: Now list all the available records.      String sql = "SELECT id, first, last, age FROM Employees";      ResultSet rs = stmt.executeQuery(sql);      System.out.println("List result set for reference....");      printRs(rs);      //STEP 10: Clean-up environment      rs.close();      stmt.close();      conn.close();   }catch(SQLException se){      //Handle errors for JDBC      se.printStackTrace();      // If there is an error then rollback the changes.      System.out.println("Rolling back data here....");      try{         if(conn!=null)            conn.rollback();      }catch(SQLException se2){         se2.printStackTrace();      }//end try   }catch(Exception e){      //Handle errors for Class.forName      e.printStackTrace();   }finally{      //finally block used to close resources      try{         if(stmt!=null)            stmt.close();      }catch(SQLException se2){      }// nothing we can do      try{         if(conn!=null)            conn.close();      }catch(SQLException se){         se.printStackTrace();      }//end finally try   }//end try   System.out.println("Goodbye!");}//end main   public static void printRs(ResultSet rs) throws SQLException{      //Ensure we start with first row      rs.beforeFirst();      while(rs.next()){         //Retrieve by column name         int id  = rs.getInt("id");         int age = rs.getInt("age");         String first = rs.getString("first");         String last = rs.getString("last");         //Display values         System.out.print("ID: " + id);         System.out.print(", Age: " + age);         System.out.print(", First: " + first);         System.out.println(", Last: " + last);     }     System.out.println();   }//end printRs()}//end JDBCExample

现在让我们来编译上面的例子如下：

C:\>javac JDBCExample.javaC:\>当运行JDBCExample，它会产生以下结果：C:\>java JDBCExampleConnecting to database...Creating statement...Inserting one row....Commiting data here....List result set for reference....ID: 100, Age: 18, First: Zara, Last: AliID: 101, Age: 25, First: Mahnaz, Last: FatmaID: 102, Age: 30, First: Zaid, Last: KhanID: 103, Age: 28, First: Sumit, Last: MittalID: 106, Age: 20, First: Rita, Last: TezID: 107, Age: 22, First: Sita, Last: SinghGoodbye!C:\>