diff --git a/.classpath b/.classpath new file mode 100644 index 0000000..790fd63 --- /dev/null +++ b/.classpath @@ -0,0 +1,33 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + diff --git a/.gitignore b/.gitignore new file mode 100644 index 0000000..ca6e3d3 --- /dev/null +++ b/.gitignore @@ -0,0 +1,5 @@ +target/ +lib_managed/ +src_managed/ +project/boot/ +bin/ diff --git a/.project b/.project new file mode 100644 index 0000000..76a8171 --- /dev/null +++ b/.project @@ -0,0 +1,18 @@ + + + sinist + + + + + + org.scala-ide.sdt.core.scalabuilder + + + + + + org.scala-ide.sdt.core.scalanature + org.eclipse.jdt.core.javanature + + diff --git a/.scala_dependencies b/.scala_dependencies new file mode 100644 index 0000000..74fc0e0 --- /dev/null +++ b/.scala_dependencies @@ -0,0 +1,13 @@ +/Users/fsteeg/Documents/workspaces/sinist/bin:/Users/fsteeg/Documents/workspaces/sinist/project/boot/scala-2.7.7/org.scala-tools.sbt/sbt/0.7.4/classpath_2.7.7-0.7.4.jar:/Users/fsteeg/Documents/workspaces/sinist/project/boot/scala-2.7.7/org.scala-tools.sbt/sbt/0.7.4/compile_2.7.7-0.7.4.jar:/Users/fsteeg/Documents/workspaces/sinist/project/boot/scala-2.7.7/org.scala-tools.sbt/sbt/0.7.4/compiler-interface-bin_2.7.7.final/compiler-interface-bin-0.7.4.jar:/Users/fsteeg/Documents/workspaces/sinist/project/boot/scala-2.7.7/org.scala-tools.sbt/sbt/0.7.4/compiler-interface-bin_2.8.0.RC2/compiler-interface-bin-0.7.4.jar:/Users/fsteeg/Documents/workspaces/sinist/project/boot/scala-2.7.7/org.scala-tools.sbt/sbt/0.7.4/compiler-interface-src/compiler-interface-src-0.7.4.jar:/Users/fsteeg/Documents/workspaces/sinist/project/boot/scala-2.7.7/org.scala-tools.sbt/sbt/0.7.4/compiler-interface-src/jline-0.9.94.jar:/Users/fsteeg/Documents/workspaces/sinist/project/boot/scala-2.7.7/org.scala-tools.sbt/sbt/0.7.4/control_2.7.7-0.7.4.jar:/Users/fsteeg/Documents/workspaces/sinist/project/boot/scala-2.7.7/org.scala-tools.sbt/sbt/0.7.4/io_2.7.7-0.7.4.jar:/Users/fsteeg/Documents/workspaces/sinist/project/boot/scala-2.7.7/org.scala-tools.sbt/sbt/0.7.4/ivy_2.7.7-0.7.4.jar:/Users/fsteeg/Documents/workspaces/sinist/project/boot/scala-2.7.7/org.scala-tools.sbt/sbt/0.7.4/ivy-2.1.0.jar:/Users/fsteeg/Documents/workspaces/sinist/project/boot/scala-2.7.7/org.scala-tools.sbt/sbt/0.7.4/jsch-0.1.31.jar:/Users/fsteeg/Documents/workspaces/sinist/project/boot/scala-2.7.7/org.scala-tools.sbt/sbt/0.7.4/launcher-interface-0.7.4.jar:/Users/fsteeg/Documents/workspaces/sinist/project/boot/scala-2.7.7/org.scala-tools.sbt/sbt/0.7.4/sbt_2.7.7-0.7.4.jar:/Users/fsteeg/Documents/workspaces/sinist/project/boot/scala-2.7.7/org.scala-tools.sbt/sbt/0.7.4/test-interface-0.5.jar:/Users/fsteeg/Documents/workspaces/sinist/project/boot/scala-2.7.7/org.scala-tools.sbt/sbt/0.7.4/xsbti/interface-0.7.4.jar:/Users/fsteeg/Documents/workspaces/sinist/project/boot/scala-2.8.0/lib/scala-compiler.jar:/Users/fsteeg/Documents/workspaces/sinist/project/boot/scala-2.8.0/lib/scala-library.jar:/Users/fsteeg/Documents/workspaces/sinist/lib/exist.jar:/Users/fsteeg/Documents/workspaces/sinist/lib_managed/scala_2.8.0/compile/junit-4.8.1.jar:/sinist/lib_managed/scala_2.8.0/compile/junit-4.1.jar:/Users/fsteeg/Documents/workspaces/sinist/lib_managed/scala_2.8.0/compile/scalatest-1.2.jar:/Users/fsteeg/Documents/workspaces/sinist/lib_managed/scala_2.8.0/compile/xercesImpl-2.9.1.jar:/Users/fsteeg/Documents/workspaces/sinist/lib_managed/scala_2.8.0/compile/xml-apis-1.3.04.jar:/Users/fsteeg/Documents/workspaces/sinist/lib_managed/scala_2.8.0/compile/log4j-1.2.16.jar:/Users/fsteeg/Documents/workspaces/sinist/lib_managed/scala_2.8.0/compile/ws-commons-util-1.0.2.jar:/Users/fsteeg/Documents/workspaces/sinist/lib/xmldb.jar:/Users/fsteeg/Documents/eclipse/configuration/org.eclipse.osgi/bundles/379/1/.cp/lib/scala-library.jar:/Users/fsteeg/Documents/eclipse/configuration/org.eclipse.osgi/bundles/379/1/.cp/lib/scala-dbc.jar:/Users/fsteeg/Documents/eclipse/configuration/org.eclipse.osgi/bundles/379/1/.cp/lib/scala-swing.jar:/System/Library/Frameworks/JavaVM.framework/Versions/1.6.0/Classes/classes.jar:/System/Library/Frameworks/JavaVM.framework/Frameworks/JavaRuntimeSupport.framework/Resources/Java/JavaRuntimeSupport.jar:/System/Library/Frameworks/JavaVM.framework/Versions/1.6.0/Classes/ui.jar:/System/Library/Frameworks/JavaVM.framework/Versions/1.6.0/Classes/jsse.jar:/System/Library/Frameworks/JavaVM.framework/Versions/1.6.0/Classes/jce.jar:/System/Library/Frameworks/JavaVM.framework/Versions/1.6.0/Classes/charsets.jar:/System/Library/Java/Extensions/AppleScriptEngine.jar:/System/Library/Java/Extensions/dns_sd.jar:/System/Library/Java/Extensions/j3daudio.jar:/System/Library/Java/Extensions/j3dcore.jar:/System/Library/Java/Extensions/j3dutils.jar:/System/Library/Java/Extensions/jai_codec.jar:/System/Library/Java/Extensions/jai_core.jar:/System/Library/Java/Extensions/mlibwrapper_jai.jar:/System/Library/Java/Extensions/MRJToolkit.jar:/System/Library/Java/Extensions/QTJava.zip:/System/Library/Java/Extensions/vecmath.jar:/System/Library/Frameworks/JavaVM.framework/Versions/1.6.0/Home/lib/ext/apple_provider.jar:/System/Library/Frameworks/JavaVM.framework/Versions/1.6.0/Home/lib/ext/dnsns.jar:/System/Library/Frameworks/JavaVM.framework/Versions/1.6.0/Home/lib/ext/localedata.jar:/System/Library/Frameworks/JavaVM.framework/Versions/1.6.0/Home/lib/ext/sunjce_provider.jar:/System/Library/Frameworks/JavaVM.framework/Versions/1.6.0/Home/lib/ext/sunpkcs11.jar +------- +/Users/fsteeg/Documents/workspaces/sinist/src/test/scala/com/quui/sinist/XmlDbSpec.scala -> /Users/fsteeg/Documents/workspaces/sinist/src/main/scala/com/quui/sinist/XmlDb.scala +/Users/fsteeg/Documents/workspaces/sinist/src/test/scala/com/quui/sinist/XmlDbSpec.scala -> /Users/fsteeg/Documents/workspaces/sinist/src/test/scala/com/quui/sinist/XmlDbSpec.scala +------- +/Users/fsteeg/Documents/workspaces/sinist/src/test/scala/com/quui/sinist/XmlDbSpec.scala -> /Users/fsteeg/Documents/workspaces/sinist/bin/com/quui/sinist/XmlDbSpec$$anonfun$1$$anonfun$apply$mcV$sp$1.class +/Users/fsteeg/Documents/workspaces/sinist/src/test/scala/com/quui/sinist/XmlDbSpec.scala -> /Users/fsteeg/Documents/workspaces/sinist/bin/com/quui/sinist/XmlDbSpec$$anonfun$1$$anonfun$apply$mcV$sp$2.class +/Users/fsteeg/Documents/workspaces/sinist/src/test/scala/com/quui/sinist/XmlDbSpec.scala -> /Users/fsteeg/Documents/workspaces/sinist/bin/com/quui/sinist/XmlDbSpec$$anonfun$1$$anonfun$apply$mcV$sp$3.class +/Users/fsteeg/Documents/workspaces/sinist/src/test/scala/com/quui/sinist/XmlDbSpec.scala -> /Users/fsteeg/Documents/workspaces/sinist/bin/com/quui/sinist/XmlDbSpec.class +/Users/fsteeg/Documents/workspaces/sinist/src/test/scala/com/quui/sinist/XmlDbSpec.scala -> /Users/fsteeg/Documents/workspaces/sinist/bin/com/quui/sinist/XmlDbSpec$$anonfun$1$$anonfun$apply$mcV$sp$5.class +/Users/fsteeg/Documents/workspaces/sinist/src/test/scala/com/quui/sinist/XmlDbSpec.scala -> /Users/fsteeg/Documents/workspaces/sinist/bin/com/quui/sinist/XmlDbSpec$$anonfun$1$$anonfun$apply$mcV$sp$4.class +/Users/fsteeg/Documents/workspaces/sinist/src/test/scala/com/quui/sinist/XmlDbSpec.scala -> /Users/fsteeg/Documents/workspaces/sinist/bin/com/quui/sinist/XmlDbSpec$$anonfun$1$$anonfun$apply$mcV$sp$6.class +/Users/fsteeg/Documents/workspaces/sinist/src/test/scala/com/quui/sinist/XmlDbSpec.scala -> /Users/fsteeg/Documents/workspaces/sinist/bin/com/quui/sinist/XmlDbSpec$$anonfun$1.class diff --git a/README.textile b/README.textile new file mode 100644 index 0000000..ce2220e --- /dev/null +++ b/README.textile @@ -0,0 +1,20 @@ +**A simple (and very early) Scala wrapper to access "eXist DB":http://exist.sourceforge.net/ and potentially other XML:DB implementations** + +The basic idea (some background and details can be found in "this blog post":http://fsteeg.wordpress.com/2010/08/30/scala-object-persistence-and-the-original-nosql-xml/): + +bc. +val db = XmlDb() // pass optional location, root and collection prefix +db.putXml(element, collId, xmlDocId) +db.putBin("data".getBytes, collId, binDocId) +val xml: Option[List[Elem]] = db.getXml(collId) +val bin: Option[List[Array[Byte]]] = db.getBin(collId) + +To run the tests, have an eXist DB running via @startup.sh@ at @xmldb:exist://localhost:8080/exist/xmlrpc@ + +Building with "SBT":http://code.google.com/p/simple-build-tool/: + +* update +* test +* package + +This will fetch dependencies, run the tests, and create a jar in the @target@ directory. \ No newline at end of file diff --git a/epl-v10.html b/epl-v10.html new file mode 100644 index 0000000..3998fce --- /dev/null +++ b/epl-v10.html @@ -0,0 +1,261 @@ + + + + + + +Eclipse Public License - Version 1.0 + + + + + + +

Eclipse Public License - v 1.0

+ +

THE ACCOMPANYING PROGRAM IS PROVIDED UNDER THE TERMS OF THIS ECLIPSE +PUBLIC LICENSE ("AGREEMENT"). ANY USE, REPRODUCTION OR +DISTRIBUTION OF THE PROGRAM CONSTITUTES RECIPIENT'S ACCEPTANCE OF THIS +AGREEMENT.

+ +

1. DEFINITIONS

+ +

"Contribution" means:

+ +

a) in the case of the initial Contributor, the initial +code and documentation distributed under this Agreement, and

+

b) in the case of each subsequent Contributor:

+

i) changes to the Program, and

+

ii) additions to the Program;

+

where such changes and/or additions to the Program +originate from and are distributed by that particular Contributor. A +Contribution 'originates' from a Contributor if it was added to the +Program by such Contributor itself or anyone acting on such +Contributor's behalf. Contributions do not include additions to the +Program which: (i) are separate modules of software distributed in +conjunction with the Program under their own license agreement, and (ii) +are not derivative works of the Program.

+ +

"Contributor" means any person or entity that distributes +the Program.

+ +

"Licensed Patents" mean patent claims licensable by a +Contributor which are necessarily infringed by the use or sale of its +Contribution alone or when combined with the Program.

+ +

"Program" means the Contributions distributed in accordance +with this Agreement.

+ +

"Recipient" means anyone who receives the Program under +this Agreement, including all Contributors.

+ +

2. GRANT OF RIGHTS

+ +

a) Subject to the terms of this Agreement, each +Contributor hereby grants Recipient a non-exclusive, worldwide, +royalty-free copyright license to reproduce, prepare derivative works +of, publicly display, publicly perform, distribute and sublicense the +Contribution of such Contributor, if any, and such derivative works, in +source code and object code form.

+ +

b) Subject to the terms of this Agreement, each +Contributor hereby grants Recipient a non-exclusive, worldwide, +royalty-free patent license under Licensed Patents to make, use, sell, +offer to sell, import and otherwise transfer the Contribution of such +Contributor, if any, in source code and object code form. This patent +license shall apply to the combination of the Contribution and the +Program if, at the time the Contribution is added by the Contributor, +such addition of the Contribution causes such combination to be covered +by the Licensed Patents. The patent license shall not apply to any other +combinations which include the Contribution. No hardware per se is +licensed hereunder.

+ +

c) Recipient understands that although each Contributor +grants the licenses to its Contributions set forth herein, no assurances +are provided by any Contributor that the Program does not infringe the +patent or other intellectual property rights of any other entity. Each +Contributor disclaims any liability to Recipient for claims brought by +any other entity based on infringement of intellectual property rights +or otherwise. As a condition to exercising the rights and licenses +granted hereunder, each Recipient hereby assumes sole responsibility to +secure any other intellectual property rights needed, if any. For +example, if a third party patent license is required to allow Recipient +to distribute the Program, it is Recipient's responsibility to acquire +that license before distributing the Program.

+ +

d) Each Contributor represents that to its knowledge it +has sufficient copyright rights in its Contribution, if any, to grant +the copyright license set forth in this Agreement.

+ +

3. REQUIREMENTS

+ +

A Contributor may choose to distribute the Program in object code +form under its own license agreement, provided that:

+ +

a) it complies with the terms and conditions of this +Agreement; and

+ +

b) its license agreement:

+ +

i) effectively disclaims on behalf of all Contributors +all warranties and conditions, express and implied, including warranties +or conditions of title and non-infringement, and implied warranties or +conditions of merchantability and fitness for a particular purpose;

+ +

ii) effectively excludes on behalf of all Contributors +all liability for damages, including direct, indirect, special, +incidental and consequential damages, such as lost profits;

+ +

iii) states that any provisions which differ from this +Agreement are offered by that Contributor alone and not by any other +party; and

+ +

iv) states that source code for the Program is available +from such Contributor, and informs licensees how to obtain it in a +reasonable manner on or through a medium customarily used for software +exchange.

+ +

When the Program is made available in source code form:

+ +

a) it must be made available under this Agreement; and

+ +

b) a copy of this Agreement must be included with each +copy of the Program.

+ +

Contributors may not remove or alter any copyright notices contained +within the Program.

+ +

Each Contributor must identify itself as the originator of its +Contribution, if any, in a manner that reasonably allows subsequent +Recipients to identify the originator of the Contribution.

+ +

4. COMMERCIAL DISTRIBUTION

+ +

Commercial distributors of software may accept certain +responsibilities with respect to end users, business partners and the +like. While this license is intended to facilitate the commercial use of +the Program, the Contributor who includes the Program in a commercial +product offering should do so in a manner which does not create +potential liability for other Contributors. Therefore, if a Contributor +includes the Program in a commercial product offering, such Contributor +("Commercial Contributor") hereby agrees to defend and +indemnify every other Contributor ("Indemnified Contributor") +against any losses, damages and costs (collectively "Losses") +arising from claims, lawsuits and other legal actions brought by a third +party against the Indemnified Contributor to the extent caused by the +acts or omissions of such Commercial Contributor in connection with its +distribution of the Program in a commercial product offering. The +obligations in this section do not apply to any claims or Losses +relating to any actual or alleged intellectual property infringement. In +order to qualify, an Indemnified Contributor must: a) promptly notify +the Commercial Contributor in writing of such claim, and b) allow the +Commercial Contributor to control, and cooperate with the Commercial +Contributor in, the defense and any related settlement negotiations. The +Indemnified Contributor may participate in any such claim at its own +expense.

+ +

For example, a Contributor might include the Program in a commercial +product offering, Product X. That Contributor is then a Commercial +Contributor. If that Commercial Contributor then makes performance +claims, or offers warranties related to Product X, those performance +claims and warranties are such Commercial Contributor's responsibility +alone. Under this section, the Commercial Contributor would have to +defend claims against the other Contributors related to those +performance claims and warranties, and if a court requires any other +Contributor to pay any damages as a result, the Commercial Contributor +must pay those damages.

+ +

5. NO WARRANTY

+ +

EXCEPT AS EXPRESSLY SET FORTH IN THIS AGREEMENT, THE PROGRAM IS +PROVIDED ON AN "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS +OF ANY KIND, EITHER EXPRESS OR IMPLIED INCLUDING, WITHOUT LIMITATION, +ANY WARRANTIES OR CONDITIONS OF TITLE, NON-INFRINGEMENT, MERCHANTABILITY +OR FITNESS FOR A PARTICULAR PURPOSE. Each Recipient is solely +responsible for determining the appropriateness of using and +distributing the Program and assumes all risks associated with its +exercise of rights under this Agreement , including but not limited to +the risks and costs of program errors, compliance with applicable laws, +damage to or loss of data, programs or equipment, and unavailability or +interruption of operations.

+ +

6. DISCLAIMER OF LIABILITY

+ +

EXCEPT AS EXPRESSLY SET FORTH IN THIS AGREEMENT, NEITHER RECIPIENT +NOR ANY CONTRIBUTORS SHALL HAVE ANY LIABILITY FOR ANY DIRECT, INDIRECT, +INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING +WITHOUT LIMITATION LOST PROFITS), HOWEVER CAUSED AND ON ANY THEORY OF +LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING +NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OR +DISTRIBUTION OF THE PROGRAM OR THE EXERCISE OF ANY RIGHTS GRANTED +HEREUNDER, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGES.

+ +

7. GENERAL

+ +

If any provision of this Agreement is invalid or unenforceable under +applicable law, it shall not affect the validity or enforceability of +the remainder of the terms of this Agreement, and without further action +by the parties hereto, such provision shall be reformed to the minimum +extent necessary to make such provision valid and enforceable.

+ +

If Recipient institutes patent litigation against any entity +(including a cross-claim or counterclaim in a lawsuit) alleging that the +Program itself (excluding combinations of the Program with other +software or hardware) infringes such Recipient's patent(s), then such +Recipient's rights granted under Section 2(b) shall terminate as of the +date such litigation is filed.

+ +

All Recipient's rights under this Agreement shall terminate if it +fails to comply with any of the material terms or conditions of this +Agreement and does not cure such failure in a reasonable period of time +after becoming aware of such noncompliance. If all Recipient's rights +under this Agreement terminate, Recipient agrees to cease use and +distribution of the Program as soon as reasonably practicable. However, +Recipient's obligations under this Agreement and any licenses granted by +Recipient relating to the Program shall continue and survive.

+ +

Everyone is permitted to copy and distribute copies of this +Agreement, but in order to avoid inconsistency the Agreement is +copyrighted and may only be modified in the following manner. The +Agreement Steward reserves the right to publish new versions (including +revisions) of this Agreement from time to time. No one other than the +Agreement Steward has the right to modify this Agreement. The Eclipse +Foundation is the initial Agreement Steward. The Eclipse Foundation may +assign the responsibility to serve as the Agreement Steward to a +suitable separate entity. Each new version of the Agreement will be +given a distinguishing version number. The Program (including +Contributions) may always be distributed subject to the version of the +Agreement under which it was received. In addition, after a new version +of the Agreement is published, Contributor may elect to distribute the +Program (including its Contributions) under the new version. Except as +expressly stated in Sections 2(a) and 2(b) above, Recipient receives no +rights or licenses to the intellectual property of any Contributor under +this Agreement, whether expressly, by implication, estoppel or +otherwise. All rights in the Program not expressly granted under this +Agreement are reserved.

+ +

This Agreement is governed by the laws of the State of New York and +the intellectual property laws of the United States of America. No party +to this Agreement will bring a legal action under this Agreement more +than one year after the cause of action arose. Each party waives its +rights to a jury trial in any resulting litigation.

+ + + + \ No newline at end of file diff --git a/lib/exist.jar b/lib/exist.jar new file mode 100644 index 0000000..303aa9a Binary files /dev/null and b/lib/exist.jar differ diff --git a/lib/xmldb.jar b/lib/xmldb.jar new file mode 100644 index 0000000..fbb3b8a Binary files /dev/null and b/lib/xmldb.jar differ diff --git a/project/build.properties b/project/build.properties new file mode 100644 index 0000000..1e7388c --- /dev/null +++ b/project/build.properties @@ -0,0 +1,8 @@ +#Project properties +#Wed Sep 01 23:23:03 CEST 2010 +project.organization=quui.com +project.name=sinist +sbt.version=0.7.4 +project.version=0.1.0 +build.scala.versions=2.8.0 +project.initialize=false diff --git a/project/build/SinistProject.scala b/project/build/SinistProject.scala new file mode 100644 index 0000000..2407c07 --- /dev/null +++ b/project/build/SinistProject.scala @@ -0,0 +1,18 @@ +/************************************************************************************************** + * Copyright (c) 2010 Fabian Steeg. All rights reserved. This program and the accompanying materials + * are made available under the terms of the Eclipse Public License v1.0 which accompanies this + * distribution, and is available at http://www.eclipse.org/legal/epl-v10.html + *

+ * Contributors: Fabian Steeg - initial API and implementation + *************************************************************************************************/ +import sbt._ + +class SinistProject(info: ProjectInfo) extends DefaultProject(info) { + val junit = "junit" % "junit" % "4.8.1" + val log4j = "log4j" % "log4j" % "1.2.16" + val scalaTest = "org.scalatest" % "scalatest" % "1.2" + val xerces = "xerces" % "xercesImpl" % "2.9.1" + val wsCommonsUtil = "org.apache.ws.commons.util" % "ws-commons-util" % "1.0.2" + val xmlrpcClient = "org.apache.xmlrpc" % "xmlrpc-client" % "3.1.3" + val xmlrpcCommon = "org.apache.xmlrpc" % "xmlrpc-common" % "3.1.3" +} \ No newline at end of file diff --git a/src/main/scala/com/quui/sinist/XmlDb.scala b/src/main/scala/com/quui/sinist/XmlDb.scala new file mode 100644 index 0000000..13fe5c3 --- /dev/null +++ b/src/main/scala/com/quui/sinist/XmlDb.scala @@ -0,0 +1,109 @@ +/************************************************************************************************** + * Copyright (c) 2010 Fabian Steeg. All rights reserved. This program and the accompanying materials + * are made available under the terms of the Eclipse Public License v1.0 which accompanies this + * distribution, and is available at http://www.eclipse.org/legal/epl-v10.html + *

+ * Contributors: Fabian Steeg - initial API and implementation + *************************************************************************************************/ +package com.quui.sinist + +import scala.xml.Elem +import scala.xml.XML +import java.io.File +import org.xmldb.api.base.XMLDBException +import org.xmldb.api.modules.BinaryResource +import org.xmldb.api.modules.XMLResource +import org.xmldb.api.modules.CollectionManagementService +import org.xmldb.api.DatabaseManager +import org.xmldb.api.base.Collection +import org.exist.xmldb.DatabaseImpl +/** + * Simple wrapper to the eXist XML:DB. + * @author Fabian Steeg (fsteeg) + */ +object XmlDb { + + val DefaultLocation = "xmldb:exist://localhost:8080/exist/xmlrpc" + val DefaultRoot = "/db/" + val DefaultPrefix = "" + + object Format extends Enumeration { + type Format = Value + val XML = Value(classOf[XMLResource].getSimpleName) + val BIN = Value(classOf[BinaryResource].getSimpleName) + } + + def apply( + location: String = XmlDb.DefaultLocation, + root: String = XmlDb.DefaultRoot, + prefix: String = XmlDb.DefaultPrefix) = new XmlDb(location, root, prefix) +} + +class XmlDb( + location: String = XmlDb.DefaultLocation, + root: String = XmlDb.DefaultRoot, + prefix: String = XmlDb.DefaultPrefix) { + + DatabaseManager.registerDatabase(new DatabaseImpl()) // XML:DB implementation + + def put(file: File, kind: XmlDb.Format.Value): Unit = { + put(file, new File(file.getParent).getName, file.getName, kind) + } + + def putXml(xml: Elem, coll: String, id: String): Unit = put(xml.toString, coll, id, XmlDb.Format.XML) + + def putBin(bin: Array[Byte], coll: String, id: String): Unit = put(bin, coll, id, XmlDb.Format.BIN) + + def getXml(name: String, ids: String*): Option[List[Elem]] = collection(name) match { + case None => None + case Some(coll) => { + val entryIds = if (ids.size > 0) ids else getIds(name).get + val entries = for (id <- entryIds; obj = coll.getResource(id).getContent; if obj.isInstanceOf[String]) + yield XML.loadString(obj.asInstanceOf[String]) + Some(entries.toList) + } + } + + def getBin(name: String, ids: String*): Option[List[Array[Byte]]] = collection(name) match { + case None => None + case Some(coll) => { + val entryIds = if (ids.size > 0) ids else getIds(name).get + val entries = for (id <- entryIds; obj = coll.getResource(id).getContent; if obj.isInstanceOf[Array[Byte]]) + yield obj.asInstanceOf[Array[Byte]] + Some(entries.toList) + } + } + + def getIds(name: String): Option[List[String]] = collection(name) match { + case None => None + case Some(coll) => Some(List() ++ coll.listResources) + } + + private def put(content: Object, collectionId: String, id: String, kind: XmlDb.Format.Value): Unit = { + val collectionName = prefix + collectionId + val collectionPath = root + collectionName + var collection = DatabaseManager.getCollection(location + collectionPath) + if (collection == null) collection = createCollection(collectionName) + val resource = collection.createResource(id, kind.toString) + resource.setContent(content) + collection.storeResource(resource) + } + + private def collection(name: String): Option[Collection] = { + val collection = DatabaseManager.getCollection(location + root + prefix + name) + if (collection == null) None else Some(collection) + } + + private def createCollection(name: String): Collection = { + try { + DatabaseManager.getCollection(location + root) + .getService(classOf[CollectionManagementService].getSimpleName, "1.0") + .asInstanceOf[CollectionManagementService] + .createCollection(name) + } catch { + case x: XMLDBException => throw new IllegalStateException( + "Could not create collection in DB at %s (%s)".format(location, x.getMessage), x) + } + } + +} \ No newline at end of file diff --git a/src/test/scala/com/quui/sinist/XmlDbSpec.scala b/src/test/scala/com/quui/sinist/XmlDbSpec.scala new file mode 100644 index 0000000..b0c7bec --- /dev/null +++ b/src/test/scala/com/quui/sinist/XmlDbSpec.scala @@ -0,0 +1,73 @@ +/************************************************************************************************** + * Copyright (c) 2010 Fabian Steeg. All rights reserved. This program and the accompanying materials + * are made available under the terms of the Eclipse Public License v1.0 which accompanies this + * distribution, and is available at http://www.eclipse.org/legal/epl-v10.html + *

+ * Contributors: Fabian Steeg - initial API and implementation + *************************************************************************************************/ +package com.quui.sinist + +import scala.xml._ +import org.scalatest.Spec +import org.scalatest.matchers.ShouldMatchers +import org.scalatest.junit.JUnitRunner +import org.junit.runner.RunWith +import java.io.File +/** + * Sample usage and tests for the {@link XmlDb} class. + * @author Fabian Steeg + */ +@RunWith(classOf[JUnitRunner]) +class XmlDbSpec extends Spec with ShouldMatchers { + + describe("The XmlDb") { + + val db = XmlDb() // pass optional location, root and collection prefix + val coll = "test-coll" + val xml: Elem = element + val xmlDocId = "test-xml-id" + val binDocId = "test-bin-id" + val pretty = new PrettyPrinter(200, 2) + + it("can be used to store and retrieve XML elements") { + expect(pretty format xml) { + db.putXml(xml, coll, xmlDocId) + val res: Elem = db.getXml(coll, xmlDocId).get(0) + pretty format res + } + } + + it("can be used to store and retrieve binary data") { + val bin: Array[Byte] = "data".getBytes + expect(new String(bin)) { + db.putBin(bin, coll, binDocId) + val res: Array[Byte] = db.getBin(coll, binDocId).get(0) + new String(res) + } + } + + it("allows access to all ids of stored pages of a collection") { + expect(2) { db.getIds(coll).get.size } // we added on XML, one BIN + + } + + it("returns all entries for a specific format if no ids are given") { + expect(1) { db.getXml(coll).get.size } // we added one XML + expect(1) { db.getBin(coll).get.size } // we added one BIN + } + + it("returns optional lists of Elem or Array[Byte] objects") { + expect(classOf[Elem]) { db.getXml(coll, xmlDocId).get(0).getClass } + expect(classOf[Array[Byte]]) { db.getBin(coll, binDocId).get(0).getClass } + } + + it("allows to retrieve XML for manipulation and store it back") { + val oldXml = db.getXml(coll, xmlDocId).get(0) + expect(pretty format { oldXml }) { + db.putXml({ oldXml }, coll, xmlDocId) + pretty format db.getXml(coll, xmlDocId).get(0) + } + } + + } +} \ No newline at end of file