• Home
  • home > java > jdbc >

    完整java开发中JDBC连接数据库代码和步骤

    Author：[email protected] Date：

    JDBC规范采用接口和实现分离的思想设计了Java数据库编程的框架。接口包含在java sql及javax sql包中，其中java sql属于JavaSE，javax sql属于JavaEE。这些接口的实现类叫做数据库驱动程序，由数据库的厂
     

    什么是JDBC?

    Java语言访问数据库的一种规范,是一套API

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

    结果集ResultSet

    while(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类型 技术手册P421

    PreparedStatement（预编语句）

    PreparedStatement stmt = conn.prepareStatement("insert into test(id,name)values(?,?)");

    stmt.setInt(1,id);

    stmt.setString(2,name);

    注：一旦设定语句的参数值后，就可以多次执行改语句，直到调用clearParameters（）方法将他清除为止

    CallableStatement（预储程序）技术手册P430

    JDBC2.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

     

    resultSetType

    TYPE_FORWARD_ONLY            只能使用next（）方法。

    TYPE_SCROLL_SENSITIVE        可以上下移动，可以取得改变后的值。

    TYPE_SCROLL_INSENSITIVE      可以上下移动。

    resultSetConcuttency

    CONCUR_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.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=select CURRENT_DATE

    jdbc-0.proxool.verbose=true

    jdbc-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);


     

     
     
    分类: java
     
    8
    0
     
    (请您对文章做出评价)
     
    « 上一篇：Export/Import 使用技巧与常见错误
    » 下一篇：安装Linux是出现 Uncompressing Linux Kernel .. ok 问题处理

      1.  

      2.  
      3.  
      4. JDBC连接数据库   
      5. •创建一个以JDBC连接数据库的程序，包含7个步骤：   
      6.  1、加载JDBC驱动程序：   
      7.     在连接数据库之前，首先要加载想要连接的数据库的驱动到JVM（Java虚拟机），   
      8.     这通过java.lang.Class类的静态方法forName(String  className)实现。   
      9.     例如：   
      10.     try{   
      11.     //加载MySql的驱动类   
      12.     Class.forName("com.mysql.jdbc.Driver") ;   
      13.     }catch(ClassNotFoundException e){   
      14.     System.out.println("找不到驱动程序类 ，加载驱动失败！");   
      15.     e.printStackTrace() ;   
      16.     }   
      17.    成功加载后，会将Driver类的实例注册到DriverManager类中。   
      18.  2、提供JDBC连接的URL   
      19.    •连接URL定义了连接数据库时的协议、子协议、数据源标识。   
      20.     •书写形式：协议：子协议：数据源标识   
      21.     协议：在JDBC中总是以jdbc开始   
      22.     子协议：是桥连接的驱动程序或是数据库管理系统名称。   
      23.     数据源标识：标记找到数据库来源的地址与连接端口。   
      24.     例如：（MySql的连接URL）   
      25.     jdbc:mysql:   
      26.         //localhost:3306/test?useUnicode=true&characterEncoding=gbk ;   
      27.    useUnicode=true：表示使用Unicode字符集。如果characterEncoding设置为   
      28.    gb2312或GBK，本参数必须设置为true 。characterEncoding=gbk：字符编码方式。   
      29.  3、创建数据库的连接   
      30.     •要连接数据库，需要向java.sql.DriverManager请求并获得Connection对象，   
      31.      该对象就代表一个数据库的连接。   
      32.     •使用DriverManager的getConnectin(String url , String username ,    
      33.     String password )方法传入指定的欲连接的数据库的路径、数据库的用户名和   
      34.      密码来获得。   
      35.      例如：   
      36.      //连接MySql数据库，用户名和密码都是root   
      37.      String url = "jdbc:mysql://localhost:3306/test" ;    
      38.      String username = "root" ;   
      39.      String password = "root" ;   
      40.      try{   
      41.     Connection con =    
      42.              DriverManager.getConnection(url , username , password ) ;   
      43.      }catch(SQLException se){   
      44.     System.out.println("数据库连接失败！");   
      45.     se.printStackTrace() ;   
      46.      }   
      47.  4、创建一个Statement   
      48.     •要执行SQL语句，必须获得java.sql.Statement实例，Statement实例分为以下3  
      49.      种类型：   
      50.       1、执行静态SQL语句。通常通过Statement实例实现。   
      51.       2、执行动态SQL语句。通常通过PreparedStatement实例实现。   
      52.       3、执行数据库存储过程。通常通过CallableStatement实例实现。   
      53.     具体的实现方式：   
      54.         Statement stmt = con.createStatement() ;   
      55.        PreparedStatement pstmt = con.prepareStatement(sql) ;   
      56.        CallableStatement cstmt =    
      57.                             con.prepareCall("{CALL demoSp(? , ?)}") ;   
      58.  5、执行SQL语句   
      59.     Statement接口提供了三种执行SQL语句的方法：executeQuery 、executeUpdate   
      60.    和execute   
      61.     1、ResultSet executeQuery(String sqlString)：执行查询数据库的SQL语句   
      62.         ，返回一个结果集（ResultSet）对象。   
      63.      2、int executeUpdate(String sqlString)：用于执行INSERT、UPDATE或   
      64.         DELETE语句以及SQL DDL语句，如：CREATE TABLE和DROP TABLE等   
      65.      3、execute(sqlString):用于执行返回多个结果集、多个更新计数或二者组合的   
      66.         语句。   
      67.    具体实现的代码：   
      68.           ResultSet rs = stmt.executeQuery("SELECT * FROM ...") ;   
      69.     int rows = stmt.executeUpdate("INSERT INTO ...") ;   
      70.     boolean flag = stmt.execute(String sql) ;   
      71.  6、处理结果   
      72.     两种情况：   
      73.      1、执行更新返回的是本次操作影响到的记录数。   
      74.      2、执行查询返回的结果是一个ResultSet对象。   
      75.     • ResultSet包含符合SQL语句中条件的所有行，并且它通过一套get方法提供了对这些   
      76.       行中数据的访问。   
      77.     • 使用结果集（ResultSet）对象的访问方法获取数据：   
      78.      while(rs.next()){   
      79.          String name = rs.getString("name") ;   
      80.     String pass = rs.getString(1) ; // 此方法比较高效   
      81.      }   
      82.     （列是从左到右编号的，并且从列1开始）   
      83.  7、关闭JDBC对象    
      84.      操作完成以后要把所有使用的JDBC对象全都关闭，以释放JDBC资源，关闭顺序和声   
      85.      明顺序相反：   
      86.      1、关闭记录集   
      87.      2、关闭声明   
      88.      3、关闭连接对象   
      89.           if(rs != null){   // 关闭记录集   
      90.         try{   
      91.             rs.close() ;   
      92.         }catch(SQLException e){   
      93.             e.printStackTrace() ;   
      94.         }   
      95.           }   
      96.           if(stmt != null){   // 关闭声明   
      97.         try{   
      98.             stmt.close() ;   
      99.         }catch(SQLException e){   
      100.             e.printStackTrace() ;   
      101.         }   
      102.           }   
      103.           if(conn != null){  // 关闭连接对象   
      104.          try{   
      105.             conn.close() ;   
      106.          }catch(SQLException e){   
      107.             e.printStackTrace() ;   
      108.          }   
      109.           }  
      110.  


    转载本站文章《完整java开发中JDBC连接数据库代码和步骤》,
    请注明出处：https://www.zhoulujun.cn/html/java/jdbc/2015_0729_204.html

    收藏
    上一篇：第一页
    下一篇：旧调重弹Hibernate与Ibatis区别——深入架构设计