XQuery， 连通SQL与NOSQL的桥梁 |走在溪边

winston

在企业应用软件设计中，原来往往只需要与一个SQL数据打交道，现在却往往要连接多个数据源，这些数据源可能是SQL数据库、NOSQL数据、XML文件、网站数据等。这么多复杂的数据，有没有办法让它们构成一个数据中心，以相对统一的方式进行管理和数据处理呢？XQuery是合适的前端。
具体做法：
1、在企业服务器上设定数据库连接池，并指定连接名称。
2、选择合适的xquery引擎，并绑定企业服务器。
3、扩展xquery的函数用于操作数据库，比如连接关系数据库，扩展以下函数，原型如下：
declare function sql:select($a as xs:string, $b as xs:string) as node() external;
declare function sql:update($a as xs:string, $b as xs:string) as xs:boolean external;

4、使用xquery查询各单元的数据，合并处理后返回结果。
5、使用xquery维护各数据单元。


这样做有以下的优缺点:
优点：
1、与Sql一样，对外提供统一查询和维护方式。
2、可以以一种统一的方式构建数据中心管理工具。
3、按数据特性，选择合适高效的存储单元。

以后的模式是否应该这样:
    一些厂商提供各种具有一定特性的(比如Sql、Cache、Xml、Json、 File)的高性能数据单元。
    一些厂商提供高性能的数据中心管理工具，主要的查询和维护语言是xquery，也可延伸sql。
     数据库厂商不需要面面俱到，只需要提供的存储单元足够高效就可以。
4、提高SQL数据库的分布性
5、提高内容的分布性。
6、更有效规划内容的存储方式。
     
缺点：
     1、xquery的性能还需要提高。
     2、增加了数据存储规划复杂性。

下面是具体使用的例子：
1、查询某类别下产品货号，类别以xml的方式保存在dbxml库，货号放在Sql Server中。

2. declare function sql:select($a as xs:string, $b
3. as xs:string) as xs:string external;
4. declare function sql:update($a as
5. xs:string, $b as xs:string) as xs:boolean external;
7. let $sTxt :=
8. xqilla:parse-xml($str)
9. let $ID := $sTxt/search/@ID
11. let $t :=
12. doc("dbxml:/product/productcategory.dbxml/data")//Category[@ID=$ID]
13. let $k :=
14. data($t/@ID|$t//Category/@ID)
15. let $s :=
16. concat("'",string-join($k,"','"),"'")
18. let $sql := <Sql>
19.         
20.     select  rtrim(ItemNo) as Code,Name,Spec  from ItemDetail  where CategoryID
21. in ({$s})
22.                 order by ItemNo
23.             FOR XML PATH
24. ('Product'),ROOT ('Products')
25.         </Sql>
27. let $link :=
28. "link_erp1"
29. return  
30. sql:select($link,$sql/text())
33. 2、使用xquery查询企业资源。
35. declare namespace fx = "http://local";
36. declare function sql:select($a
37. as xs:string, $b as xs:string) as node() external;
38. declare function
39. sql:update($a as xs:string, $b as xs:string) as xs:boolean
40. external;
42. declare function fx:trim( $arg as xs:string? )  as
43. xs:string
44. {
45.     replace(replace($arg,'\s+
47. [img=1,1]http://www.cnblogs.com/qianxj/aggbug/2168502.html?type=1[/img]
48. [url=http://www.cnblogs.com/qianxj/archive/2011/12/08/2168502.html]本文链接[/url],''),'^\s+','')
49. }
50. ;
52. (:let $ResourceType :="Supplier":)
53. (:let $ResourceType
54. :="Customer":)
55. (:let $ResourceType :="Goods":)
57. let $PageSize := 50
59. let $PageIndex := 1
61. let $link := "link_erp1"
62. return
63. (
64.    
65. if($ResourceType="Supplier") then
66.     (
67.         let $query :=
68. <sql>
69.             DECLARE @PageSize int
70.             DECLARE
71. @PageIndex int
73.             set @PageSize = {$PageSize};
74.             
75. set @PageIndex = {$PageIndex};
77.             WITH Temp AS
78.             
79. (
80.               SELECT ROW_NUMBER() OVER(ORDER BY SupplierNo ASC) AS
81. RowNumber,*
82.               FROM Supplier1
83.             )
85.             
86. SELECT  rtrim(SupplierID) as "@guid",
87.                      rtrim(SupplierNo)
88. as SupplierNo,
89.                      rtrim(SupplierShort) as ShortName,
90.    
91.                  rtrim(SupplierName) as Name,
92.                      
93. rtrim(SupplierAddress) as Address,
94.                      rtrim(CountryNo) as
95. Country,
96.                      rtrim(ProvinceNo) as Province
97.             
98.       FROM Temp
99.             WHERE (RowNumber BETWEEN @PageSize*(@PageIndex-1)
100. + 1 AND @PageSize * @PageIndex )
101.             FOR XML PATH ('Supplier'),ROOT
102. ('Suppliers')
103.         </sql>
104.         return
105. sql:select($link,$query/text())
106.     )
107.     else
108. if($ResourceType="Customer") then
109.     (
110.         let $query :=
111. <sql>
112.             DECLARE @PageSize int
113.             DECLARE
114. @PageIndex int
116.             set @PageSize = {$PageSize};
117.             
118. set @PageIndex = {$PageIndex};
120.             WITH Temp AS
121.             
122. (
123.               SELECT ROW_NUMBER() OVER(ORDER BY CustomerNo ASC) AS
124. RowNumber,*
125.               FROM Customer
126.             )
128.             
129. SELECT     rtrim(CustomerID) as "@guid",
130.                     
131. rtrim(CustomerNo) as CustomerNo,
132.                     rtrim(CustomerShort) as
133. ShortName,
134.                     rtrim(CustomerName) as Name,
135.             
136.         rtrim(CustomerAddress) as Address,
137.                     rtrim(Country)
138. as Country
139.             FROM Temp
140.             WHERE (RowNumber BETWEEN
141. @PageSize*(@PageIndex-1) + 1 AND @PageSize * @PageIndex )
142.             FOR
143. XML PATH ('Customer'),ROOT ('Customers')
144.         </sql>
145.         
146. return sql:select($link,$query/text())
147.     )else
148.     ()
149. )

复制代码

本文链接