TUSCANY-3522: Apply couchdb-api.path from Eranda for the NoSQL GSoC project.

git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@1134696 13f79535-47bb-0310-9956-ffa450edef68

9 files changed, 390 insertions, 0 deletions

diff --git a/collaboration/GSoC-2011-Eranda/couchdb/pom.xml b/collaboration/GSoC-2011-Eranda/couchdb/pom.xml
new file mode 100644
index 0000000000..858e7fac59
--- /dev/null
+++ b/collaboration/GSoC-2011-Eranda/couchdb/pom.xml
@@ -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>
diff --git a/collaboration/GSoC-2011-Eranda/couchdb/src/main/java/org/apache/tuscany/nosqldatastore/Database.java b/collaboration/GSoC-2011-Eranda/couchdb/src/main/java/org/apache/tuscany/nosqldatastore/Database.java
new file mode 100644
index 0000000000..ad80b06f04
--- /dev/null
+++ b/collaboration/GSoC-2011-Eranda/couchdb/src/main/java/org/apache/tuscany/nosqldatastore/Database.java
@@ -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);
+}
diff --git a/collaboration/GSoC-2011-Eranda/couchdb/src/main/java/org/apache/tuscany/nosqldatastore/Group.java b/collaboration/GSoC-2011-Eranda/couchdb/src/main/java/org/apache/tuscany/nosqldatastore/Group.java
new file mode 100644
index 0000000000..634ab59cf0
--- /dev/null
+++ b/collaboration/GSoC-2011-Eranda/couchdb/src/main/java/org/apache/tuscany/nosqldatastore/Group.java
@@ -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);
+}
diff --git a/collaboration/GSoC-2011-Eranda/couchdb/src/main/java/org/apache/tuscany/nosqldatastore/Session.java b/collaboration/GSoC-2011-Eranda/couchdb/src/main/java/org/apache/tuscany/nosqldatastore/Session.java
new file mode 100644
index 0000000000..5aa9641715
--- /dev/null
+++ b/collaboration/GSoC-2011-Eranda/couchdb/src/main/java/org/apache/tuscany/nosqldatastore/Session.java
@@ -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);
+}
diff --git a/collaboration/GSoC-2011-Eranda/couchdb/src/main/java/org/apache/tuscany/nosqldatastore/SessionFactory.java b/collaboration/GSoC-2011-Eranda/couchdb/src/main/java/org/apache/tuscany/nosqldatastore/SessionFactory.java
new file mode 100644
index 0000000000..2438adf228
--- /dev/null
+++ b/collaboration/GSoC-2011-Eranda/couchdb/src/main/java/org/apache/tuscany/nosqldatastore/SessionFactory.java
@@ -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;
+	}
+	
+}
diff --git a/collaboration/GSoC-2011-Eranda/couchdb/src/main/java/org/apache/tuscany/nosqldatastore/couchdb/CouchDBDatatabase.java b/collaboration/GSoC-2011-Eranda/couchdb/src/main/java/org/apache/tuscany/nosqldatastore/couchdb/CouchDBDatatabase.java
new file mode 100644
index 0000000000..20e426a1c4
--- /dev/null
+++ b/collaboration/GSoC-2011-Eranda/couchdb/src/main/java/org/apache/tuscany/nosqldatastore/couchdb/CouchDBDatatabase.java
@@ -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);
+    }
+}
diff --git a/collaboration/GSoC-2011-Eranda/couchdb/src/main/java/org/apache/tuscany/nosqldatastore/couchdb/CouchDBGroup.java b/collaboration/GSoC-2011-Eranda/couchdb/src/main/java/org/apache/tuscany/nosqldatastore/couchdb/CouchDBGroup.java
new file mode 100644
index 0000000000..2590dacc0c
--- /dev/null
+++ b/collaboration/GSoC-2011-Eranda/couchdb/src/main/java/org/apache/tuscany/nosqldatastore/couchdb/CouchDBGroup.java
@@ -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);
+    }
+}
diff --git a/collaboration/GSoC-2011-Eranda/couchdb/src/main/java/org/apache/tuscany/nosqldatastore/couchdb/CouchDBSession.java b/collaboration/GSoC-2011-Eranda/couchdb/src/main/java/org/apache/tuscany/nosqldatastore/couchdb/CouchDBSession.java
new file mode 100644
index 0000000000..3805d03283
--- /dev/null
+++ b/collaboration/GSoC-2011-Eranda/couchdb/src/main/java/org/apache/tuscany/nosqldatastore/couchdb/CouchDBSession.java
@@ -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);                                                     
+    }
+}
diff --git a/collaboration/GSoC-2011-Eranda/couchdb/src/test/java/org/apache/tuscany/nosqldatastore/couchdb/CouchDBTest.java b/collaboration/GSoC-2011-Eranda/couchdb/src/test/java/org/apache/tuscany/nosqldatastore/couchdb/CouchDBTest.java
new file mode 100644
index 0000000000..387dd357a2
--- /dev/null
+++ b/collaboration/GSoC-2011-Eranda/couchdb/src/test/java/org/apache/tuscany/nosqldatastore/couchdb/CouchDBTest.java
@@ -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");
+
+
+    }
+}