本文給出了一個使用apache sdo處理xml數(shù)據(jù)的例子。由于sdo現(xiàn)在還不是處理xml的標(biāo)準(zhǔn)的解決方案，因此，本文還討論了sdo中的基本的操作xml數(shù)據(jù)的方法。
跟蹤數(shù)據(jù)的變化在很多軟件、應(yīng)用程序和商業(yè)場景中是一個基本的要求。如果要嚴(yán)格地實現(xiàn)這個需求是非常困難的，這主要是因為對文件的不同變化建模，并監(jiān)視這些變化一般很難做到。從另一方面講，在所有的程序中反復(fù)地實現(xiàn)這種功能要比將一個單獨的模塊應(yīng)用到不同的應(yīng)用程序中更經(jīng)濟(jì)實用。而服務(wù)數(shù)據(jù)對象（sdo），這個由bea和ibm定義的異構(gòu)數(shù)據(jù)訪問解決方案，為開發(fā)人員提供了更容易實現(xiàn)的機制來從系統(tǒng)層跟蹤數(shù)據(jù)的變化。
一、處理xml數(shù)據(jù)的三個階段
在本文給出的處理xml的例子分為三個不同的階段，這些階段如下：
1. 建立
2. 處理
3. 瀏覽
xml數(shù)據(jù)可以通過一個文件系統(tǒng)在這三個階段之間進(jìn)行傳輸。在本例的中心場景如下：第二步需要記錄xml文件在第一階段被建立的記錄，當(dāng)?shù)谌綖g覽xml數(shù)據(jù)時，人們總希望知道這個文件有哪些變化。如果我們使用word的跟蹤特性，我們將會立即獲得這些變化的值。
許多應(yīng)用程序都有這些需求，包括實現(xiàn)并發(fā)控制、離線應(yīng)用程序的同步，商業(yè)進(jìn)程管理（bpm）系統(tǒng)。這部分將演示sdo如何幫助我們更容易地實現(xiàn)這些需求。
本文提供的xml數(shù)據(jù)是一個訂購數(shù)據(jù)，代碼如下：
<?xml version="1.0" encoding="utf-8"?> <xsd:import namespace="commonj.sdo/xml" schemalocation="sdo.xsd"/> <xsd:complextype name="purchaseordertype"> <xsd:complextype name="usaddress"> <xsd:simpletype name="sku"> |
createpo.java類完成了建立xml的工作。代碼如下
| package com.company.sdo.po; import commonj.sdo.dataobject; import commonj.sdo.helper.datafactory; public class createpo { public static void main(string[] args) throws exception { //1. 使用xsd定義類型和屬性 util.definepotypes(); //2. 建立根dataobject dataobject purchaseorder = datafactory.instance.create(constants.po_namespace, "purchaseordertype"); //3. 設(shè)置根dataobject的數(shù)據(jù)類型屬性 purchaseorder.setstring("orderdate", "1999-10-20"); //4. 建立子dataobject dataobject shipto = purchaseorder.createdataobject("shipto"); //5. 設(shè)置子dataobject的數(shù)據(jù)類型屬性 shipto.set("country", "us"); shipto.set("name", "alice smith"); shipto.set("street", "123 maple street"); shipto.set("city", "mill valley"); shipto.set("state", "ca"); shipto.setstring("zip", "90952"); dataobject billto = purchaseorder.createdataobject("billto"); billto.set("country", "us"); billto.set("name", "robert smith"); billto.set("street", "8 oak avenue"); billto.set("city", "mill valley"); billto.set("state", "pa"); billto.setstring("zip", "95819"); purchaseorder.set("comment", "hurry, my lawn is going wild!"); dataobject items = purchaseorder.createdataobject("items"); //6. 為子dataobject “item”建立一個子dataobject dataobject item1 = items.createdataobject("item"); item1.set("partnum", "872-aa"); item1.set("productname", "lawnmower"); item1.setint("quantity", 1); item1.setstring("price", "148.95"); item1.set("comment", "confirm this is electric"); dataobject item2 = items.createdataobject("item"); item2.set("partnum", "926-aa"); item2.set("productname", "baby monitor"); item2.setint("quantity", 1); item2.setstring("price", "39.98"); item2.setstring("shipdate", "2007-11-21"); dataobject item3 = items.createdataobject("item"); item3.set("partnum", "998-aa"); item3.set("productname", "carpet"); item3.setint("quantity", 1); item3.setstring("price", "439.98"); item3.setstring("shipdate", "2007-12-01"); //7. 將xml數(shù)據(jù)保存在一個xml文件中 util.storexml(purchaseorder,"purchaseorder", constants.po_xml); } } |
1. 使用xsd定義類型和屬性；由于我們的數(shù)據(jù)是基于xml格式的，因此，我們首先需要在運行時定義sdo類型的屬性。這個功能由util類的definepotypes()方法完成。在definepotypes方法內(nèi)部調(diào)用了xsdhelper類。definepotypes()方法的代碼如下：
| public static void definepotypes() throws exception { fileinputstream fis = new fileinputstream(po_model_original); xsdhelper.instance.define(fis, null); fis.close(); } |
2. 建立根數(shù)據(jù)對象：sdo的動態(tài)api可以通過數(shù)據(jù)對象的層次和屬性或是一個datagraph（包含了數(shù)據(jù)對象元數(shù)據(jù)的一個圖）來描述結(jié)構(gòu)化數(shù)據(jù)。sdo提供了用于建立一個未連接的數(shù)據(jù)對象的datafactory接口。
3. 設(shè)置根數(shù)據(jù)對象的數(shù)據(jù)類型屬性：訂購單在sdo中是一個類型，并且根據(jù)schema，它有一個叫orderdate的數(shù)據(jù)類型屬性，這是一個日期類型。
4. 建立子數(shù)據(jù)對象：數(shù)據(jù)對象訂購單有一些子數(shù)據(jù)對象。例如，上面代碼中的注釋4在purchaseorder中建立shipto子結(jié)點。除了這種方法，我們還可以使用datafactory來建立一個未連接的shipto數(shù)據(jù)對象，并使用setdataobject方法將他設(shè)置成purchaseorder的一個子結(jié)點。代碼如下：
dataobject shipto = datafactory.instance.create(constants.po_namespace, "usaddress");
......
purchaseorder.setdataobject("shipto", shipto);
5. 設(shè)置子對象結(jié)點的數(shù)據(jù)類型屬性：基于usaddress類型的定義，shipto數(shù)據(jù)對象有不同的數(shù)據(jù)類型屬性。上面注釋5建立了這些屬性。
6. 為子數(shù)據(jù)對象“item”建立一個子數(shù)據(jù)對象：這部分顯示了建立xml時sdo數(shù)據(jù)模型。
在下一部分將討論如何使用sdo的動態(tài)api，我們可以編輯訂購單，并且在同時跟蹤他們的變化。
|||
三、記錄處理xml數(shù)據(jù)的變化
我們可以利用在sdo中定義的changesummary機制來跟蹤訂購單的變化。為了實現(xiàn)我們的第二個目的，我們先來編輯一個這個xml的schema文件po_orginal.xsd。代碼如下：
<xsd:schema xmlns:xsd="http://www.w3.org/2001/xmlschema" <xsd:import namespace="commonj.sdo/xml" <xsd:complextype name="purchaseordertype"> |
這個被導(dǎo)入的sdo.xsd定義了changesummarytype。我們在purchaseordertype中加一個changesummarytype的元素。我們可以將這個元素命名為任何東西，當(dāng)然，除了使用“changes”。
為了使用新的schema，我們需要使用util類的definepotypes()方法來裝載它。我們將要保存被createpo.java產(chǎn)生的xml文件為po.xml。這個文件和po_original.xml比較得知，po.xml在<po:purchaseorder>: <changes logging="false" />中有一個新的子元素。processpo.java類處理訂購單。當(dāng)運行時，程序保存了這個處理過程，并在po_processed.xml中產(chǎn)生了一條變化記錄。po_processed.xml的代碼如下：
| <?xml version="1.0" encoding="ascii"?> <po:purchaseorder xmlns:po="http://www.example.com/po" orderdate="1999-10-20"> <shipto country="us"> <name>alice smith</name> <street>123 maple street</street> <city>mill valley</city> <state>ca</state> <zip>90952</zip> </shipto> <billto country="us"> <name>alice smith</name> <street>8 oak avenue</street> <city>mill valley</city> <state>pa</state> <zip>95819</zip> </billto> <po:comment>hurry, my lawn is going wild!</po:comment> <items> <item partnum="872-aa"> <productname>lawnmower</productname> <price>148.95</price> <quantity>1</quantity> <po:comment>confirm this is electric</po:comment> </item> <item partnum="926-aa"> <productname>baby monitor</productname> <price>39.98</price> <quantity>2</quantity> <shipdate>2007-11-21</shipdate> </item> <item partnum="999-aa"> <productname>armed chair</productname> <price>299.95</price> <quantity>1</quantity> <po:comment>make sure the cover is leather.</po:comment> </item> </items> <changes create=" ##//items/item[3]" delete=" ##//changes/items[1]/item[3]" logging="false" xmlns:sdo="commonj.sdo"> <billto sdo:ref=" ##//billto"> <name>robert smith</name> </billto> <item sdo:ref=" ##//items/item[2]"> <quantity>1</quantity> </item> <items sdo:ref=" ##//items"> <item sdo:ref=" ##//items/item[1]" /> <item sdo:ref=" ##//items/item[2]" /> <item partnum="998-aa"><productname>carpet</productname><price>439.98</price><quantity>1</quantity><shipdate>2007-12-01</shipdate></item> </items> </changes> </po:purchaseorder> |
上面的代碼顯示了xml文件的變化記錄，但是我們更感興趣的是<changes>元素，這個元素現(xiàn)在變得更復(fù)雜了。這個元素捕捉了訂購單的所有的變化。基本這些變化，應(yīng)用程序可以恢復(fù)以前的未變化的數(shù)據(jù)。
現(xiàn)在讓我我們看一下processpo.java類，并分析一個sdo如何允許我們獲得這樣詳細(xì)的變化數(shù)據(jù)。
1. 注釋1中在運行時轉(zhuǎn)載了po.xml。
2. 注釋2建立了和purchaseorder數(shù)據(jù)對象相關(guān)的changesummary對象。
3. 為了跟蹤變化，注釋3打開了changesummary對象的日志功能。
4. 在注釋4中，日志是關(guān)閉的，purchaseorder的所有變化和它的子數(shù)據(jù)對象在changesummary對象中被捕捉。
5. 在注釋5中輸出了結(jié)果，我們可以看看util類中的printchangesummary方法，代碼如下：
| public static void printchangesummary(changesummary chngsum) { if (chngsum == null) { system.out.println("changesummary is not in existence!"); return; } for (iterator it = chngsum.getchangeddataobjects().iterator(); it.hasnext();) { dataobject changedobject = (dataobject) it.next(); system.out.println(); if (chngsum.iscreated(changedobject)) {//is the changed object newly created system.out.println("created: " + changedobject); if (changedobject.getcontainer()!=null){ system.out.println("/t--- to be contained in : " + changedobject.getcontainer().gettype().getname() + " ---"); }else{ system.out.println("/t--- created object has no container --- "); } printannotateddataobject("newly created",changedobject, 2); } else if (chngsum.isdeleted(changedobject)) { system.out.println("deleted: " + changedobject); if (chngsum.getoldcontainer(changedobject) != null){ system.out.println("/t--- originally contained in : " + chngsum.getoldcontainer(changedobject).gettype().getname() + " ---"); }else{ system.out.println("/t--- deleted object has no container ---"); } // a potential bug in tuscany sdo, this shows nothing in processpo.java printannotateddataobject("deleted",changedobject, 2); // drill down to deleted property system.out.println("/t--- deleted property information --- "); // a potential bug in tuscany sdo, this section shows nothing in reviewpo.java for (iterator settingit = chngsum.getoldvalues(changedobject).iterator(); settingit.hasnext();) { printdeletedproperty((changesummary.setting) settingit.next()); } system.out.println("/t--- deleted property information --- "); } else if (chngsum.ismodified(changedobject)) { system.out.println("updated: " + changedobject); // print out the updated object printannotateddataobject("after update", changedobject, 2); // drill down to changed property system.out.println("/t--- property update information --- "); for (iterator settingit = chngsum.getoldvalues(changedobject).iterator(); settingit.hasnext();) { changesummary.setting changesetting = (changesummary.setting) settingit.next(); printupdatedproperty(changesetting, changedobject,chngsum); } system.out.println("/t--- property update information --- "); } else system.out.println("should never come here!"); } } |
在這個方法中，我們首先使用了getchangeddataobjects()來獲得所有變化了的數(shù)據(jù)對象，然后按著他們的種類處理，即建立、刪除或編輯。如果數(shù)據(jù)對象是新建的，我們會打印對象的信息和所有的屬性。
在下一部分，我們來瀏覽被編輯的訂購單。
四、通過一個不同的實體瀏覽數(shù)據(jù)的變化
xml數(shù)據(jù)處理的第三部分需要完成兩個任務(wù)：
1. 程序需要按著編輯順序打印出主要的信息。
2. 顯示處理階段所有的修改記錄。
當(dāng)我們可以更進(jìn)一步根據(jù)著一個記錄變化階段編輯訂購單時，這部分顯示了如何使用reviewpo.java調(diào)用所有的編輯記錄。reviewpo.java的代碼如下：
| package com.company.sdo.po; import java.io.fileinputstream; import java.util.list; import commonj.sdo.changesummary; import commonj.sdo.dataobject; import commonj.sdo.helper.xmldocument; import commonj.sdo.helper.xmlhelper; public class reviewpo { public static void main(string[] args) throws exception { util.definepotypes(); fileinputstream fis = new fileinputstream(constants.po_processed_xml); //1. 裝載要處理的訂購單 xmldocument xmldoc = xmlhelper.instance.load(fis); dataobject purchaseorder = xmldoc.getrootobject(); //2. 顯示被編輯的訂購單的信息 system.out.println(); system.out.println("---received purchase order information---"); system.out.println("order date: " + purchaseorder.get("orderdate")); system.out.println("order comment: " + purchaseorder.get("comment")); dataobject shipto = purchaseorder.getdataobject("shipto"); system.out.println("ship to name: "); util.printdataobject(shipto,1); dataobject billto = purchaseorder.getdataobject("billto"); system.out.println("bill to name: "); util.printdataobject(billto,1); dataobject items = purchaseorder.getdataobject("items"); list itemlist = items.getlist("item"); system.out.println("ordered items: "); for (int i = 0; i < itemlist.size(); i++) { dataobject item = (dataobject) itemlist.get(i); system.out.println("/titem " + (i+1) + " :" ); util.printdataobject(item,2); } //3. 顯示了第二階段的數(shù)據(jù)變化 system.out.println(); system.out.println("---review changes in purchase order ---"); changesummary chngsum = purchaseorder.getchangesummary(); util.printchangesummary(chngsum); //4. 取消第二階段的所有變化 system.out.println(); system.out.println("---action taken after reviewing the changes---"); system.out.println("/t###undo all changes###"); chngsum.undochanges(); //5. 編輯訂購單的原始版本 system.out.println(); system.out.println("---changes made in purchase order review---"); chngsum.beginlogging(); billto.set("name", "alice smith"); chngsum.endlogging(); //6. 將新的變化輸出到系統(tǒng)控制臺 util.printchangesummary(chngsum); //7. 將改變記錄保存到一個xml文件中 util.storexml(purchaseorder,"purchaseorder", constants.po_reviewed_xml); } } |
要注意的是第二個任務(wù)不同于在前一部分打印changesummary，在這里printout是直接基于changesummary的。變化細(xì)節(jié)在運行時被重新裝載。我們可以通過比較這兩個printout來分辨它們的不同。在上一部分，printdataobject()在刪除項時什么都沒產(chǎn)生，而是調(diào)用了printdeletedproperty()來列出它們的屬性和它們的值。在當(dāng)前的printout中，恰恰相反。
在程序的其他部分，注釋4通過調(diào)用undochanges方法取消了在第二階段的所有的變化，注釋5對訂購單做了一些小的變化。我們可以看看保存變化記錄的文件（po_reviewed.xml）來驗證這些操作結(jié)果。
新聞熱點
疑難解答
