教您使用XML封装数据库操作语句的实现
作者： 来源： 添加时间：2006-5-21 20:25:36好的，在分析了XML文件之后需要我们进入到程序的设计上来了。从以上实现的分析我们可以清楚的看到要实现以上操作，我们必须要做到以下几步：
1：读取XML文件
2：定位相应的交易节点
3：拼SQL 语句
4：数据库操作
5：取数据
6：返回数据
其中针对第一步的读取文件，我们可以封装所有的XML parse语句以及前期的操作封装进入一个类之中，这里我们命名为 XMLLoadFile。
交易处理的过程包括2，5，6三个步骤，可以封装成XMLTransaction类中。当然返回数据这个操作可以单独抽出来作为一个相应的返回类，如果这样是为了在返回的数据报文做处理，比如可以返回XML，Vector或者Hashtable或Map等。这里暂定返回数据为Vector类型，所以将第6步封装进来。
拼装SQL语句，独立建立一个类（XMLCombine），当然也可以分为多个，比如SelectCombine，insertCombine等，这里我们进行统一封装。
数据库操作单独封装成一个类，XMLExecuteSQL。
以上所有的类统一了一个出口类，这里为XMLUtils。这个类提供的几个方法为外部数据操作的主要方法，比如select, insert, delete, update等，还有提供外部程序存取数据的几个方法，比如：setTransNode(设置交易节点)，setTransValue(设置交易数据值), setTransKeyValue(设置交易键值数据值)
三、外部程序调用
对于select语句，分析1
所需编写的程序如下：
XMLUtils util = new XMLUtils();util.setTransNode(“selectUser”);Vector vRtn = util.select( con ); |
分析2为：
XMLUtils util = new XMLUtils();util.setTransNode(“selectUserByKey”);util.setTransKeyValue(“userid”, 123 );Vector vRtn = util.select( con ); |
对于insert语句，分析5）程序如下：
XMLUtils util = new XMLUtils();util.setTransNode(“insertUser”);util.setTransValue(“username”, “test” );util.setTransValue(“password”, “test” );Vector vRtn = util.insert( con ); //假设操作成功long userid = ((Long)((Hashtable)vRtn.elementAt(0)).get(“userid”)).longValue();util.setTransNode(“insertUserInfo”);util.setTransValue(“userid”, userid );util.setTransValue(“email”, “test@test.com” );util.setTransValue(“mobile”, “1234567890” );Vector vRtn = util.insert( con ); |
对于 delete语句 分析 6）程序如下：
XMLUtils util = new XMLUtils();util.setTransNode(“deleteUser”);util.setTransKeyValue(“userid”, 100);util.delete( con ); |
对于update语句,分析 8）程序如下：
XMLUtils util = new XMLUtils();util.setTransNode(“updateUserInfo”);util.setTransKeyValue(“userid”, 123);util.setTransValue(“email”, “aaa@aaa.com”);util.update( con ); |
大家在看这些SQL的操作时，是不是觉得很工整，也很舒服呢？这样做的好处很多，程序员可以不必太多的去拼写SQL语句，封装的操作可以使所有程序员的程序都可以写的很工整，并有统一的风格。
import com.iart.DataBase.XMLControl.*;import com.microsoft.*; import java.sql.*;import java.util.*;public class Sample{ public static void main( String[] args ) { XMLUtils util = new XMLUtils(); Connection con = null; try{ System.out.println ("[StartupServlet]begin ===================== ========================="); util.StartupServlet(); System.out.println("[StartupServlet]end ===================== ========================="); con = getConnection(); System.out.println ("[GetConnection]"+ con.toString() ); // /* util.setTransNode( "clear" ); util.clear(con); util.setTransNode( "setpassbyname" ); util.setTransValue( "logonname", "keli2" ); util.setTransValue( "username", "keli3" ); util.setTransValue( "password", "hnh3" ); util.insert(con);*/ util.setTransNode ("backemail","selectRespCode"); //util.setTransKeyValue ( "starttime","2003-08-22 00:00:00.0" ); //util.setTransKeyValue ( "endtime","2003-08-22 23:59:59.0" ); //util.setTransKeyValue ( "docstatusid","2" ); //util.setTransValue ( "createtime","CURRENT_TIMESTAMP" ); /* util.setTransNode("insertDocument"); util.setTransValue( "doctypeid", "2"); util.setTransValue( "docstatusid", "1" ); Vector vRtn = util.insert(con);*/ Hashtable vRtn = util.select(con, 0, -1 ); System.out.println(vRtn.toString()); System.out.println (((Vector)vRtn.get("DATA")).size()); util.setTransNode ("backemail","selectRespCode"); vRtn = util.select(con, 2, 20 ); System.out.println(vRtn.toString()); System.out.println (((Vector)vRtn.get("DATA")).size()); vRtn = util.select(con,3, 20 ); System.out.println(vRtn.toString()); System.out.println (((Vector)vRtn.get("DATA")).size()); /* util.setTransNode("selectmaxdoc"); Vector vResult = util.select(con); Long docid = (Long) ((Hashtable)vResult.elementAt(0)).get("docid"); util.setTransNode ("insertEmail"); util.setTransValue ( "mid", docid.toString()); util.setTransValue ( "subject", "test" ); util.setTransValue ( "targetaddr", "test@test.com" ); util.setTransValue ( "sourceaddr", "test@test.com" ); util.setTransValue ( "content", "test@test.com" ); util.insert(con); util.setTransNode("selectemail"); Vector vResult1 = util.select(con); for( int i=0; i< vResult1.size(); i++ ) { Hashtable vColumn = (Hashtable)vResult1.elementAt(i); if( vColumn != null ) System.out.println ("1"+vColumn.toString() ); } */ /* util.setTransNode( "deletebyname" ); util.setTransKeyValue ("logonname", "keli"); util.delete(con); util.setTransNode ("getpassbyname"); util.setTransKeyValue ( "logonname", "%keli%" ); Vector vResult2 = util.select(con); for( int i=0; i< vResult2.size(); i++ ) { Hashtable vColumn = (Hashtable)vResult2.elementAt(i); if( vColumn != null ) System.out.println (vColumn.toString() ); }*/ }catch( Exception ex ) { ex.printStackTrace(); }finally{ try{ con.close(); }catch(Exception ex1) { System.out.println(ex1.getMessage()); } } } public static Connection getConnection() throws Exception { Class.forName ("com.microsoft.jdbc. sqlserver.SQLServerDriver"); String strCon = "jdbc:microsoft:sqlserver: //localhost:1433;User=nlc; Password=nlc;DatabaseName=nlc"; Connection conn = DriverManager.getConnection(strCon); return conn; }} |
第 2 页，共 2 页 [1] [2]
站内搜索