| java操作DB2 XML数据实践
自学了90分钟的DB2 XQuery，还不很熟悉，就要在项目中用了，心里很不踏实，还是先跑个CRUD的Demo看看，以免走弯路。
代码很粗糙，主要目的是看看JDBC是否能很好的执行这种新SQL，呵呵。
另外，在此之前，看到oracle老大已经开始实现一个操作XML数据的规范，目前还没有正式出台，希望Sun能尽快跟进，将标准的API接口定出来，以支持广大的java社区。项目有期限，我们也没时间等Sun给我们做好任何东西，自己动手实现吧。
下面是我做的一个Demo，希望能给正在研究这一块的朋友一点参考，XQuery SQL代码参考了DB2官方文档。
一、实现一个简单的数据库工具import java.sql.*；
* 简单的数据连接工具
* File: DBUtils.java
* User: leizhimin
* Date: 2008-3-18 15:19:12
*/
public class DBUtils {
public static final String url = "jdbc:db2://192.168.3.143:50000/lavasoft";
public static final String username = "lavasoft";
public static final String password = "lavasoftdb2";
public static final String driverClassName = "com.ibm.db2.jcc.DB2Driver";
/**
* 获取数据库连接Connection
*
* @return 数据库连接Connection
*/
public static Connection makeConnection() {
Connection conn = null;
try {
Class.forName(driverClassName);
} catch (ClassNotFoundException e) {
e.printStackTrace();
}
try {
conn = DriverManager.getConnection(url, username, password);
} catch (SQLException e) {
e.printStackTrace();
}
return conn;
}
public static void main(String args[]) {
testConnection();
}
/**
* 测试连接方法
*/
public static void testConnection() {
Connection conn = makeConnection();
try {
Statement stmt = conn.createStatement();
ResultSet rs = stmt.executeQuery("SELECT * FROM DM_HYML");
while (rs.next()) {
String s1 = rs.getString(1);
String s2 = rs.getString(2);
System.out.println(s1 + s2);
}
rs.close();
stmt.close();
} catch (SQLException e) {
e.printStackTrace();
} finally {
try {
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
}
二、写一个简单的测试类执行各种XQuery SQL
import com.topsoft.icib.common.utils.DBUtils;
import java.sql.*;
import java.io.ByteArrayInputStream;
import java.io.InputStream;
import java.io.IOException;
/**
* DB2 XML数据操作测试
* File: TestXMLDAO.java
* User: leizhimin
* Date: 2008-3-18 16:33:51
*/
public class TestDB2XML {
/**
* 预删除表Customer
*
* @throws SQLException
*/
public static void testDropXMLTable() throws SQLException {
String drop_sql = "DROP TABLE Customer";
Connection conn = DBUtils.makeConnection();
Statement stmt = conn.createStatement();
stmt.executeUpdate(drop_sql);
stmt.close();
conn.close();
}
/** [1] [2] [3] 下一页 |
