Java程序与数据库连接
一个网络关系数据库应用系统是一个三层次结构。客户机与服务器采用网络连接,客户机端应用程序按通信协议与服务器端的数据库程序通信;数据库服务程序通过SQL命令与数据库管理系统通信。
Java程序与数据库连接方法有两种。
一种是使用JDBC-ODBC桥接器与数据库连接,
一种是用纯Java的JDBC驱动程序实现与数据库连接。
使用JDBC-ODBC 桥接器与数据库连接
Java程序使用JDBC-ODBC 桥接器与数据库连接,Java程序与数据库通信的过程是:
先由数据库应用程序向ODBC驱动管理器发出API调用,ODBC驱动管理器将这个调用转换成向数据库管理系统的ODBC驱动程序调用,数据库管理系统又将这个调用转换成对操作系统的数据输入/输出调用。最后,操作系统从数据库中得到实际数据逐级返回。
数据库编程首先要设置数据源,在ODBC中设置数据源的步骤如下:
打开Windows控制面板中的管理工具。对于windows XP:选择“性能维护”>>“管理工具”>>“数据源(ODBC)”; 对于windows 2000:选择“管理工具”>>“数据源”。
打开“数据源”。出现ODBC数据源管理器对话框,显示现有的数据源名称。
选择“用户DSN”,单击“添加”按钮,出现安装数据源驱动程序对话框。Access(*.mdb)数据源,单击“完成”按钮,出现“创建数据源对话框,键入需要创建的数据源名,并为创建的数据源选择一个数据库表。
单击数据库区域的“选择”按钮,选择需要的数据库表。当需要为数据源授权访问级别时,单击“高级”按钮。设置登录名和密码后,单击“确定”按钮,完成Access数据库在ODBC管理器中的配置。
如果还没有数据库表,则需创建一个数据库表。
数据源就是数据库,在设定了数据源的基础上,Java程序要访问数据库表,还要建立JDBC-ODBC桥接器,让程序与数据库连接。以后,程序就可向数据库发送SQL语句,处理数据库返回的结果。
Java数据库连接JDBC(Java DataBase Connectivity)由一组用Java语言编写的类和接口组成,JDBC是Java程序与数据库连接API。它能做以下三件事情:与某个数据库建立连接、向数据库发送SQL语句和处理数据库返回的结果。
调用类方法Class.forName(String s)能建立JDBC-ODBC桥接器。例如,代码:
try{ Class.forName(“sun.jdbc.odbc.JdbcOdbcDriver”); }catch(Exception e){}
为Java程序加载了驱动程序。
【例 13-7】说明与数据库连接的方法connectByJdbcOdbc(),该方法按给定的数据库URL、用户名和密码连接数据库,如果连接成功,方法返回连接对象,连接不成功,则返回空(查看源文件)。
用纯Java的JDBC驱动程序实现与数据库连接
Java程序也可以用纯Java的JDBC驱动程序实现与数据库连接。这种方法应用较广泛,但是需要下载相应的驱动程序包,因为不同的数据库的连接代码可能不同,连接不同的数据库,加载的驱动程序也可能不同。
例如,连接SQLServer的驱动程序在www.msdn.com网站下载,有3个包:msbase.jar,mssqlserver.jar和msutil.jar,并要求将这3个包放在jdk\jre\lib\ext\目录下,或在CLASSPATH中设置其放置位置。
连接MySQL的驱动程序,1个包:mysql-connector-java-3.1.11-bin.jar
使用纯Java的JDBC驱动程序实现与数据库连接的过程如下:
加载驱动程序。有两种加载驱动程序的方式:
一个是将驱动程序添加到java.lang.System的属性jdbc.drivers中。这是一个DriverManager类加载驱动程序类名的列表,表元用冒号分隔。
另一种方式是从相关的网站下载驱动程序后,在程序中利用Class.forName()方法加载指定的驱动程序。例如:
Class.forName(“com.microsoft.jdbc.sqlserver.SQLServerDriver”); Class.forName("com.mysql.jdbc.Driver");//加载特定的驱动程序
创建指定数据库的URL。数据库的URL对象类似网络的统一资源定位符,其格式是:
subprotocol:subName://hostName:port/DatabaseName
其中,subprotocol是某种驱动程序支持的数据库连接机制; subName是当前连接机制下的具体名称;hostName是主机名;port是相应的连接端口;DatabaseName是要连接的数据库名称。例如,以下代码可以是一个数据库的URL:
jdbc:Microsoft:sqlserver://localhost:1433;Databasename=ksinfo jdbc:mysql://localhost:3306/数据库名
该数据库的URL说明利用miscrosoft提供的机制,用sqlserve驱动,通过1433端口访问本机上的ksInfo数据库。
建立连接。驱动程序管理器(DriverManager)的方法getConnection()建立连接。
使用纯Java的JDBC驱动程序实现与数据库连接的步骤如下:
1.下载相应的驱动程序包,如:连接Mysql数据驱动包为:mysql-connector-java-3.1.11-bin.jar
2. 加载驱动程序, Class.forName(“com.mysql.jdbc.Driver”);//加载特定的驱动程序
3. Connection con = DriverManage.getConnection(“jdbc:mysql://localhost:3306/数据库名”, username, password);
【例 13-8】说明与数据库连接的静态方法connectByJdbc(),该方法按给定的数据库URL、用户名和密码连接数据库,如果连接成功,方法返回true,连接不成功,则返回false。
public static Connection conectByJdbc(String url, String username, String password){ String url = "jdbc:mysql://localhost:3306/scxh"; Connection con = null; try{ Class.forName("com.mysql.jdbc.Driver");//加载特定的驱动程序 } catch (Exception e){ e.printStackTrace(); return null; //连接失败 } try{ con = DriverManage.getConnection(url, username, password); } catch (SQLException e){ e.printStackTrace(); return null; //连接失败 } return con; //连接成功 }
编写访问数据库的Java程序还需要几个重要的类和接口。
DriverManager类
DriverManager类处理驱动程序的加载和建立新数据库连接。DriverManager是java.sql包中用于管理数据库驱动程序的类。通常,应用程序只使用类DriverManager的getConnection()静态方法,用来建立与数据库的连接,返回Connection对象:
static Connection getConnection(String url,String username,String password)
指定数据的URL用户名和密码创建数据库连接对象。url的语法格式是:
jdbc:<数据库的连接机制>:<ODBC数据库名>。
Connection类
Connection类是java.sql包中用于处理与特定数据库连接的类。Connection对象是用来表示数据库连接的对象,Java程序对数据库的操作都在这种对象上进行。Connection类的主要方法有:
Statement createStatement():创建一个Statement对象。 Statement createStatement(int resultSetType,int resultSetConcurrency):创建一个Statement对象,生成具有特定类型的结果集。 void commit(): 提交对数据库的改动并释放当前持有的数据库的锁。 void rollback(): 回滚当前事务中的所有改动并释放当前连接持有的数据库的锁。 String getCatalog(): 获得连接对象的当前目录。 boolean isClose(): 判断连接是否已关闭。 boolean isReadOnly(): 判断连接是否为只读模式。 void setReadOnly(): 设置连接为只读模式。 void close(): 释放连接对象的数据库和JDBC资源。
Statement类
Statement类是java.sql包中用于在指定的连接中处理SQL语句的类。数据库编程的要点是在程序中嵌入SQL命令。程序需要声明和创建连接数据库的Connection对象,并让该对象连接数据库。调用类DriverManager的静态方法getConnection()获得Connection对象,实现程序与数据库的连。然后,用Statement类声明SQL语句对象,并调用Connection对象的createStatement()方法,创建SQL语句对象。例如,以下代码创建语句对象sql:
Statement sql = null; try{ sql = con.createStatement(); }catch(SQLException e){}
ResultSet类
有了SQL语句对象后,调用语句对象的方法executeQuery()执行SQL查询,并将查询结果存放在一个用ResultSet类声明的对象中,例如,以下代码读取学生成绩表存于rs 对象中:
ResultSet rs = sql.executeQuery(“SELECT * FROM ksInfo”);
ResultSet对象实际上是一个由查询结果数据的表,是一个管式数据集,由统一形式的数据行组成,一行对应一条查询记录。在ResultSet对象中隐含着一个游标,一次只能获得游标当前所指的数据行,用next方法可取下一个数据行。用数据行的字段(列)名称或位置索引(自1开始)调用形如getXXX()方法获得记录的字段植 。以下是ResultSet对象的部分方法:
byte getByte(int columnIndex): 返回指定字段的字节值。 Date getDate(int columnIndex): 返回指定字段的日期值。 float getFloat(int columnIndex): 返回指定字段的浮点值。 int getInt(int columnIndex): 返回指定字段的整数值。 String getString(int columnIndex): 返回指定字段的字符串值。 double getDouble(String columnName):返回指定字段的双精度值。 long getLong(String columnName): 返回指定字段的long型整值。 boolean next():返回是否还有下一字段。
以上方法中的columnIndex是位置索引,用于指定字段,columnName是字段名。
用户需要在查询结果集上浏览,或前后移动、或显示结果集的指定记录,这称为可滚动结果集。程序要获得一个可滚动结果集,只要在获得SQL的语句对象时,增加指定结果集的两个参数即可。例如,以下代码:
Statement stmt = con.createStatement(type,concurrency); ResultSet rs = stmt.executeQuery(SQL语句) 语句对象stmt的SQL查询就能得到相应类型的结果集。 int 型参数type决定可滚动集的滚动方式: ResultSet.TYPE_FORWORD_ONLY,结果集的游标只能向下滚动。 ResultSet.TYPE_SCROLL_INSENSITIVE,游标可上下移动,当数据库变化时,当前结果集不变。 ResultSet. TYPE_SCROLL_SENSITIVE,游标可上下移动,当数据库变化时,当前结果集同步改变。 int 型参数concurrency决定数据库是否与可滚动集同步更新: ResultSet.CONCUR_READ_ONLY,不能用结果集更新数据库中的表。 ResultSet.CONCUR_UPDATETABLE,能用结果集更新数据库中的表。
例如,以下代码利用连接对象connect,创建Statement对象stmt,指定结果集可滚动,并以只读方式读数据库:
stmt = connect.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,
ResultSet.CONCUR_READ_ONLY);
可滚动集上另外一些常用的方法如下:
boolean previous(): 将游标向上移动,当移到结果集的第一行时,返回false。 void beforeFirst(): 将游标移结果集的第一行之前。 void afterLast(): 将游标移到结果集的最后一行之后。 void first(): 将游标移到第一行。 void last(): 将游标移到最后一行。 boolean isAfterLast(): 判游标是否在最后一行之后。 boolean isBeforeFirst(): 判游标是否在第一行之前。 boolean isLast(): 判游标是否在最后一行。 boolean isFirst(): 判游标是否在第一行。 int getRow(): 获取当前所指的行(行号自1开始编号,结果集空,返回0)。 boolean absolute(int row): 将游标移到row行。
转载请注明来源:Java程序与数据库连接