Author: fmoga
Date: Sat Jun 11 17:02:32 2011
New Revision: 1134696
URL: http://svn.apache.org/viewvc?rev=1134696&view=rev
Log:
TUSCANY-3522: Apply couchdb-api.path from Eranda for the NoSQL GSoC project.
Added:
tuscany/collaboration/GSoC-2011-Eranda/couchdb/
tuscany/collaboration/GSoC-2011-Eranda/couchdb/pom.xml
tuscany/collaboration/GSoC-2011-Eranda/couchdb/src/
tuscany/collaboration/GSoC-2011-Eranda/couchdb/src/main/
tuscany/collaboration/GSoC-2011-Eranda/couchdb/src/main/java/
tuscany/collaboration/GSoC-2011-Eranda/couchdb/src/main/java/org/
tuscany/collaboration/GSoC-2011-Eranda/couchdb/src/main/java/org/apache/
tuscany/collaboration/GSoC-2011-Eranda/couchdb/src/main/java/org/apache/tuscany/
tuscany/collaboration/GSoC-2011-Eranda/couchdb/src/main/java/org/apache/tuscany/nosqldatastore/
tuscany/collaboration/GSoC-2011-Eranda/couchdb/src/main/java/org/apache/tuscany/nosqldatastore/Database.java
tuscany/collaboration/GSoC-2011-Eranda/couchdb/src/main/java/org/apache/tuscany/nosqldatastore/Group.java
tuscany/collaboration/GSoC-2011-Eranda/couchdb/src/main/java/org/apache/tuscany/nosqldatastore/Session.java
tuscany/collaboration/GSoC-2011-Eranda/couchdb/src/main/java/org/apache/tuscany/nosqldatastore/SessionFactory.java
tuscany/collaboration/GSoC-2011-Eranda/couchdb/src/main/java/org/apache/tuscany/nosqldatastore/couchdb/
tuscany/collaboration/GSoC-2011-Eranda/couchdb/src/main/java/org/apache/tuscany/nosqldatastore/couchdb/CouchDBDatatabase.java
tuscany/collaboration/GSoC-2011-Eranda/couchdb/src/main/java/org/apache/tuscany/nosqldatastore/couchdb/CouchDBGroup.java
tuscany/collaboration/GSoC-2011-Eranda/couchdb/src/main/java/org/apache/tuscany/nosqldatastore/couchdb/CouchDBSession.java
tuscany/collaboration/GSoC-2011-Eranda/couchdb/src/test/
tuscany/collaboration/GSoC-2011-Eranda/couchdb/src/test/java/
tuscany/collaboration/GSoC-2011-Eranda/couchdb/src/test/java/org/
tuscany/collaboration/GSoC-2011-Eranda/couchdb/src/test/java/org/apache/
tuscany/collaboration/GSoC-2011-Eranda/couchdb/src/test/java/org/apache/tuscany/
tuscany/collaboration/GSoC-2011-Eranda/couchdb/src/test/java/org/apache/tuscany/nosqldatastore/
tuscany/collaboration/GSoC-2011-Eranda/couchdb/src/test/java/org/apache/tuscany/nosqldatastore/couchdb/
tuscany/collaboration/GSoC-2011-Eranda/couchdb/src/test/java/org/apache/tuscany/nosqldatastore/couchdb/CouchDBTest.java
Added: tuscany/collaboration/GSoC-2011-Eranda/couchdb/pom.xml
URL:
http://svn.apache.org/viewvc/tuscany/collaboration/GSoC-2011-Eranda/couchdb/pom.xml?rev=1134696&view=auto
==============================================================================
--- tuscany/collaboration/GSoC-2011-Eranda/couchdb/pom.xml (added)
+++ tuscany/collaboration/GSoC-2011-Eranda/couchdb/pom.xml Sat Jun 11 17:02:32
2011
@@ -0,0 +1,56 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+Licensed to the Apache Software Foundation (ASF) under one
+or more contributor license agreements. See the NOTICE file
+distributed with this work for additional information
+regarding copyright ownership. The ASF licenses this file
+to you under the Apache License, Version 2.0 (the
+"License"); you may not use this file except in compliance
+with the License. You may obtain a copy of the License at
+
+http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing,
+software distributed under the License is distributed on an
+"AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+KIND, either express or implied. See the License for the
+specific language governing permissions and limitations
+under the License.
+-->
+<project xmlns="http://maven.apache.org/POM/4.0.0";
+ xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
+ xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
http://maven.apache.org/xsd/maven-4.0.0.xsd";>
+ <modelVersion>4.0.0</modelVersion>
+ <groupId>org.apache.tuscany</groupId>
+ <artifactId>nosql-datastore-couchdb</artifactId>
+ <version>0.0.1</version>
+
+ <packaging>jar</packaging>
+ <name>tuscany</name>
+ <url>http://maven.apache.org</url>
+ <properties>
+ <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+ </properties>
+
+ <dependencies>
+ <dependency>
+ <groupId>com.google.code.jcouchdb</groupId>
+ <artifactId>jcouchdb</artifactId>
+ <version>0.10.0-1</version>
+ </dependency>
+ </dependencies>
+
+ <build>
+ <plugins>
+ <plugin>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-compiler-plugin</artifactId>
+ <version>2.0.2</version>
+ <configuration>
+ <source>1.5</source>
+ <target>1.5</target>
+ </configuration>
+ </plugin>
+ </plugins>
+ </build>
+</project>
Added:
tuscany/collaboration/GSoC-2011-Eranda/couchdb/src/main/java/org/apache/tuscany/nosqldatastore/Database.java
URL:
http://svn.apache.org/viewvc/tuscany/collaboration/GSoC-2011-Eranda/couchdb/src/main/java/org/apache/tuscany/nosqldatastore/Database.java?rev=1134696&view=auto
==============================================================================
---
tuscany/collaboration/GSoC-2011-Eranda/couchdb/src/main/java/org/apache/tuscany/nosqldatastore/Database.java
(added)
+++
tuscany/collaboration/GSoC-2011-Eranda/couchdb/src/main/java/org/apache/tuscany/nosqldatastore/Database.java
Sat Jun 11 17:02:32 2011
@@ -0,0 +1,26 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+package org.apache.tuscany.nosqldatastore;
+
+public interface Database {
+ Group createGroup(String groupId);
+ Group getGroup(String groupId);
+ void deleteGroup(String groupId);
+}
Added:
tuscany/collaboration/GSoC-2011-Eranda/couchdb/src/main/java/org/apache/tuscany/nosqldatastore/Group.java
URL:
http://svn.apache.org/viewvc/tuscany/collaboration/GSoC-2011-Eranda/couchdb/src/main/java/org/apache/tuscany/nosqldatastore/Group.java?rev=1134696&view=auto
==============================================================================
---
tuscany/collaboration/GSoC-2011-Eranda/couchdb/src/main/java/org/apache/tuscany/nosqldatastore/Group.java
(added)
+++
tuscany/collaboration/GSoC-2011-Eranda/couchdb/src/main/java/org/apache/tuscany/nosqldatastore/Group.java
Sat Jun 11 17:02:32 2011
@@ -0,0 +1,27 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+package org.apache.tuscany.nosqldatastore;
+
+public interface Group {
+ void addEntry(String key, Object value);
+ void updateEntry(String key, Object value);
+ void deleteEntry(String key);
+ Object getValue(String key);
+}
Added:
tuscany/collaboration/GSoC-2011-Eranda/couchdb/src/main/java/org/apache/tuscany/nosqldatastore/Session.java
URL:
http://svn.apache.org/viewvc/tuscany/collaboration/GSoC-2011-Eranda/couchdb/src/main/java/org/apache/tuscany/nosqldatastore/Session.java?rev=1134696&view=auto
==============================================================================
---
tuscany/collaboration/GSoC-2011-Eranda/couchdb/src/main/java/org/apache/tuscany/nosqldatastore/Session.java
(added)
+++
tuscany/collaboration/GSoC-2011-Eranda/couchdb/src/main/java/org/apache/tuscany/nosqldatastore/Session.java
Sat Jun 11 17:02:32 2011
@@ -0,0 +1,26 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+package org.apache.tuscany.nosqldatastore;
+
+public interface Session {
+ Database createDatabase(String databaseName);
+ Database getDatabase(String databaseName);
+ void deleteDatabase(String databaseName);
+}
Added:
tuscany/collaboration/GSoC-2011-Eranda/couchdb/src/main/java/org/apache/tuscany/nosqldatastore/SessionFactory.java
URL:
http://svn.apache.org/viewvc/tuscany/collaboration/GSoC-2011-Eranda/couchdb/src/main/java/org/apache/tuscany/nosqldatastore/SessionFactory.java?rev=1134696&view=auto
==============================================================================
---
tuscany/collaboration/GSoC-2011-Eranda/couchdb/src/main/java/org/apache/tuscany/nosqldatastore/SessionFactory.java
(added)
+++
tuscany/collaboration/GSoC-2011-Eranda/couchdb/src/main/java/org/apache/tuscany/nosqldatastore/SessionFactory.java
Sat Jun 11 17:02:32 2011
@@ -0,0 +1,36 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+package org.apache.tuscany.nosqldatastore;
+
+import org.apache.tuscany.nosqldatastore.couchdb.CouchDBSession;
+
+public class SessionFactory {
+
+ private static org.apache.tuscany.nosqldatastore.Session session;
+
+ private SessionFactory(){
+ }
+
+ public static Session getCouchDBSession(){
+ session = new CouchDBSession();
+ return session;
+ }
+
+}
Added:
tuscany/collaboration/GSoC-2011-Eranda/couchdb/src/main/java/org/apache/tuscany/nosqldatastore/couchdb/CouchDBDatatabase.java
URL:
http://svn.apache.org/viewvc/tuscany/collaboration/GSoC-2011-Eranda/couchdb/src/main/java/org/apache/tuscany/nosqldatastore/couchdb/CouchDBDatatabase.java?rev=1134696&view=auto
==============================================================================
---
tuscany/collaboration/GSoC-2011-Eranda/couchdb/src/main/java/org/apache/tuscany/nosqldatastore/couchdb/CouchDBDatatabase.java
(added)
+++
tuscany/collaboration/GSoC-2011-Eranda/couchdb/src/main/java/org/apache/tuscany/nosqldatastore/couchdb/CouchDBDatatabase.java
Sat Jun 11 17:02:32 2011
@@ -0,0 +1,57 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+package org.apache.tuscany.nosqldatastore.couchdb;
+
+import org.apache.tuscany.nosqldatastore.Database;
+import org.apache.tuscany.nosqldatastore.Group;
+import org.jcouchdb.db.Server;
+import org.jcouchdb.document.DesignDocument;
+
+public class CouchDBDatatabase implements Database{
+
+ private org.jcouchdb.db.Database db;
+ private String dbname;
+
+ CouchDBDatatabase(String dbname){
+ this.dbname = dbname;
+ db = new org.jcouchdb.db.Database("localhost",dbname);
+ Server server = db.getServer();
+ if(!server.listDatabases().contains(dbname)){
+ server.createDatabase(dbname);
+ System.out.println("New database created...");
+ }
+
+ }
+
+ public Group createGroup(String groupId) {
+ CouchDBGroup group = new CouchDBGroup(db,groupId);
+ return group;
+ }
+
+ public Group getGroup(String groupId) {
+ CouchDBGroup group = new CouchDBGroup(db,groupId);
+ return group;
+ }
+
+ public void deleteGroup(String groupId) {
+ DesignDocument doc = db.getDesignDocument(groupId);
+ db.delete(doc);
+ }
+}
Added:
tuscany/collaboration/GSoC-2011-Eranda/couchdb/src/main/java/org/apache/tuscany/nosqldatastore/couchdb/CouchDBGroup.java
URL:
http://svn.apache.org/viewvc/tuscany/collaboration/GSoC-2011-Eranda/couchdb/src/main/java/org/apache/tuscany/nosqldatastore/couchdb/CouchDBGroup.java?rev=1134696&view=auto
==============================================================================
---
tuscany/collaboration/GSoC-2011-Eranda/couchdb/src/main/java/org/apache/tuscany/nosqldatastore/couchdb/CouchDBGroup.java
(added)
+++
tuscany/collaboration/GSoC-2011-Eranda/couchdb/src/main/java/org/apache/tuscany/nosqldatastore/couchdb/CouchDBGroup.java
Sat Jun 11 17:02:32 2011
@@ -0,0 +1,74 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+package org.apache.tuscany.nosqldatastore.couchdb;
+
+import org.apache.tuscany.nosqldatastore.Group;
+import org.jcouchdb.document.DesignDocument;
+import org.jcouchdb.document.DocumentHelper;
+import org.jcouchdb.exception.UpdateConflictException;
+
+import java.util.HashMap;
+import java.util.Map;
+
+public class CouchDBGroup implements Group {
+
+ private org.jcouchdb.db.Database database;
+
+ private String groupId;
+
+ CouchDBGroup(org.jcouchdb.db.Database database, String groupId){
+ this.database = database;
+ this.groupId = groupId;
+ DesignDocument doc = new DesignDocument(groupId);
+ Map<String, String> lists = new HashMap<String, String>();
+ doc.setListFunctions(lists);
+ try{
+ database.createOrUpdateDocument(doc);
+ }catch(UpdateConflictException e){
+ System.out.println("Connect to the doc "+groupId);
+ }
+ }
+
+ public void addEntry(String key, Object value) {
+ DesignDocument doc = database.getDesignDocument(groupId);
+ Map<String, String> lists = doc.getListFunctions();
+ lists.put(key, (String)value);
+ doc.setListFunctions(lists);
+ database.updateDocument(doc);
+ }
+
+ public void updateEntry(String key, Object value) {
+ addEntry(key, value);
+ }
+
+ public void deleteEntry(String key) {
+ DesignDocument doc = database.getDesignDocument(groupId);
+ Map<String, String> lists = doc.getListFunctions();
+ lists.remove(key);
+ doc.setListFunctions(lists);
+ database.updateDocument(doc);
+ }
+
+ public Object getValue(String key) {
+ DesignDocument doc = database.getDesignDocument(groupId);
+ Map<String, String> lists = doc.getListFunctions();
+ return lists.get(key);
+ }
+}
Added:
tuscany/collaboration/GSoC-2011-Eranda/couchdb/src/main/java/org/apache/tuscany/nosqldatastore/couchdb/CouchDBSession.java
URL:
http://svn.apache.org/viewvc/tuscany/collaboration/GSoC-2011-Eranda/couchdb/src/main/java/org/apache/tuscany/nosqldatastore/couchdb/CouchDBSession.java?rev=1134696&view=auto
==============================================================================
---
tuscany/collaboration/GSoC-2011-Eranda/couchdb/src/main/java/org/apache/tuscany/nosqldatastore/couchdb/CouchDBSession.java
(added)
+++
tuscany/collaboration/GSoC-2011-Eranda/couchdb/src/main/java/org/apache/tuscany/nosqldatastore/couchdb/CouchDBSession.java
Sat Jun 11 17:02:32 2011
@@ -0,0 +1,45 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+package org.apache.tuscany.nosqldatastore.couchdb;
+
+import org.apache.tuscany.nosqldatastore.Database;
+import org.apache.tuscany.nosqldatastore.Session;
+import org.jcouchdb.db.Server;
+
+public class CouchDBSession implements Session{
+
+ public CouchDBSession(){
+ }
+
+ public Database createDatabase(String databaseName) {
+ Database database = new CouchDBDatatabase(databaseName);
+ return database;
+ }
+
+ public Database getDatabase(String databaseName) {
+ Database database = new CouchDBDatatabase(databaseName);
+ return database;
+ }
+
+ public void deleteDatabase(String databaseName) {
+ org.jcouchdb.db.Database db = new
org.jcouchdb.db.Database("localhost",databaseName);
+ db.getServer().deleteDatabase(databaseName);
+ }
+}
Added:
tuscany/collaboration/GSoC-2011-Eranda/couchdb/src/test/java/org/apache/tuscany/nosqldatastore/couchdb/CouchDBTest.java
URL:
http://svn.apache.org/viewvc/tuscany/collaboration/GSoC-2011-Eranda/couchdb/src/test/java/org/apache/tuscany/nosqldatastore/couchdb/CouchDBTest.java?rev=1134696&view=auto
==============================================================================
---
tuscany/collaboration/GSoC-2011-Eranda/couchdb/src/test/java/org/apache/tuscany/nosqldatastore/couchdb/CouchDBTest.java
(added)
+++
tuscany/collaboration/GSoC-2011-Eranda/couchdb/src/test/java/org/apache/tuscany/nosqldatastore/couchdb/CouchDBTest.java
Sat Jun 11 17:02:32 2011
@@ -0,0 +1,43 @@
+package org.apache.tuscany.nosqldatastore.couchdb;
+
+import org.apache.tuscany.nosqldatastore.Database;
+import org.apache.tuscany.nosqldatastore.Group;
+import org.apache.tuscany.nosqldatastore.Session;
+import org.apache.tuscany.nosqldatastore.SessionFactory;
+
+/**
+ * Created by IntelliJ IDEA.
+ * User: eranda
+ * Date: Jun 3, 2011
+ * Time: 10:50:53 PM
+ * To change this template use File | Settings | File Templates.
+ */
+public class CouchDBTest {
+
+ Session session;
+
+ private CouchDBTest(){
+ session = SessionFactory.getCouchDBSession();
+ }
+
+ public static void main(String[] args){
+ CouchDBTest test = new CouchDBTest();
+ test.start();
+ }
+
+ public void start(){
+
+ Database db = session.createDatabase("db1");
+ Group group = db.createGroup("group4");
+ group.addEntry("eranda", "Eranda Sooriyabandara");
+ group.addEntry("ishara", "Ishara Karunarathne");
+ group.addEntry("mahesh", "Eranda Sooriyabandara");
+ group.deleteEntry("eranda");
+ group.deleteEntry("ishara");
+ System.out.println(group.getValue("mahesh"));
+ db.deleteGroup("group4");
+ session.deleteDatabase("db1");
+
+
+ }
+}
