Java与DB2数据源的连接实例

　　java与DB2数据源的连接实例

　　Java建立与DB2 数据源的连接，实现方法和思路：加载DB2 数据库驱动程序需要使用IBM 专门提供的驱动程序，加载该驱动的语句如下：

　　Class.forName("COM.ibm.db2.JDBC.app.DB2Driver").newInstance;

　　建与数据源的连接通常使用DriverManager 的getConnection方法,其调用格式共有三种，如下：

　　getConnection(String url, Properties info);

　　getConnection(String url, String user, Properties pwd);

　　getConnection(String url);

　　本例根据需要使用了后面两种格式。其中url 为使用的数据库名字，user 为数据库的用户名，pwd为用户密码。建立连接后，对数据库执行查询前，需要为用户程序创建Statement 对象：

　　Statement stmt=con. createStatement;

　　执行查询语句时，创建SQL 串，传送到DBMS 并执行SQL 语句。

　　ResultSet rs = stmt.executeQuery("SELECT * from employee");

　　对数据库建立连接后就可以对数据库进行操作。程序代码：

　　1.编写DB2Appl 类的基本框架，在该类中包括加载驱动程序的静态模块和main方法，静态模块如下：

　　static

　　{

　　try

　　{

　　// 加载驱动程序

　　// 执行此例子需要调用newInstance

　　// 注意JDk 1.1.1 以下版本 在 OS/2 上不具备Class.forName方法

　　// 执行静态初始化

　　// 可以忽略调用.

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

　　}

　　catch (Exception exec)

　　{

　　exec.printStackTrace;

　　}

　　}

　　2. 在main方法中获取数据库的用户名和密码参数，从数据库中获取数据，显示结果集并对数据库进行更新，程序代码如下：

　　public static void main(String argv)

　　{

　　Connection con = null;

　　// URL 是用户使用的数据库名

　　String url = "jdbc:db2:sample";

　　Try

　　{

　　if (argv.length == 0)

　　{

　　// 使用缺省密码连接

　　con = DriverManager.getConnection(url);

　　}

　　else if (argv.length == 2)

　　{

　　String userid = argv[0];

　　String passwd = argv[1];

　　// 使用用户名和密码连接

　　con = DriverManager.getConnection(url, userid, passwd);

　　}

　　else

　　{

　　System.out.println("\\nUsage: java DB2Appl [username password]\\n");

　　System.exit(0);

　　}

　　// 从数据库中获得数据

　　System.out.println("从数据库中获得数据");

　　Statement stmt = con.createStatement;

　　ResultSet rs = stmt.executeQuery("SELECT * from employee");

　　System.out.println("Received results:");

　　// 显示结果集

　　while (rs.next)

　　{

　　String a = rs.getString(1);

　　String str = rs.getString(2);

　　System.out.print(" empno= " + a);

　　System.out.print(" firstname= " + str);

　　System.out.print("\\n");

　　}

　　rs.close;

　　stmt.close;

　　// 对数据库进行更新

　　System.out.println("\\n\\nUpdate the database... ");

　　stmt = con.createStatement;

　　int rowsUpdated = stmt.executeUpdate("UPDATE employee set firstnme = 'LI' where empno =

　　'000001'");

　　System.out.print("Changed "+rowsUpdated);

　　if (1 == rowsUpdated)

　　System.out.println(" row.");

　　else

　　System.out.println(" rows.");

　　stmt.close;

　　con.close;

　　}

　　catch( Exception e )

　　{

　　e.printStackTrace;

　　}

　　}

　　3.因为程序使用了JDBC 类，所以需要引入如下的包：import java.sql.*;