From 15acbcd62cf8a73c86ea8bbc6ad50b9edfa2c43f Mon Sep 17 00:00:00 2001
From: Imran M Yousuf <imyousuf@smartitengineering.com>
Date: Sun, 22 Aug 2010 14:57:24 +0600
Subject: [PATCH] Add abstract common dao implementation for common write dao

In process add dependencies to HBase tests and smart abstract-dao.
Also implement the fetch by id(s) operations among the read operations.

Next will implement the search list/single object by reading the query
parameters.

Signed-off-by: Imran M Yousuf <imyousuf@smartitengineering.com>
---
 smart-hbase-dao/pom.xml                            |   9 +
 .../dao/impl/hbase/AbstractCommonDao.java          | 261 +++++++++++++++++++++
 .../com/smartitengineering/dao/impl/hbase/App.java |  13 -
 3 files changed, 270 insertions(+), 13 deletions(-)
 create mode 100644 smart-hbase-dao/src/main/java/com/smartitengineering/dao/impl/hbase/AbstractCommonDao.java
 delete mode 100644 smart-hbase-dao/src/main/java/com/smartitengineering/dao/impl/hbase/App.java

diff --git a/smart-hbase-dao/pom.xml b/smart-hbase-dao/pom.xml
index ea4adaf..6288fa8 100644
--- a/smart-hbase-dao/pom.xml
+++ b/smart-hbase-dao/pom.xml
@@ -46,6 +46,15 @@
       <groupId>com.smartitengineering</groupId>
       <artifactId>smart-dao-queryparam</artifactId>
     </dependency>
+    <dependency>
+      <groupId>com.smartitengineering</groupId>
+      <artifactId>smart-abstract-dao</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>org.apache.hbase</groupId>
+      <artifactId>hbase</artifactId>
+      <classifier>tests</classifier>
+    </dependency>
   </dependencies>
   <build>
     <plugins>
diff --git a/smart-hbase-dao/src/main/java/com/smartitengineering/dao/impl/hbase/AbstractCommonDao.java b/smart-hbase-dao/src/main/java/com/smartitengineering/dao/impl/hbase/AbstractCommonDao.java
new file mode 100644
index 0000000..7bb875d
--- /dev/null
+++ b/smart-hbase-dao/src/main/java/com/smartitengineering/dao/impl/hbase/AbstractCommonDao.java
@@ -0,0 +1,261 @@
+/*
+ * This is a common dao with basic CRUD operations and is not limited to any
+ * persistent layer implementation
+ *
+ * Copyright (C) 2010  Imran M Yousuf (imyousuf@smartitengineering.com)
+ *
+ * This library is free software; you can redistribute it and/or
+ * modify it under the terms of the GNU Lesser General Public
+ * License as published by the Free Software Foundation; either
+ * version 3 of the License, or (at your option) any later version.
+ * This library is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+ * Lesser General Public License for more details.
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this library; if not, write to the Free Software
+ * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301  USA
+ */
+package com.smartitengineering.dao.impl.hbase;
+
+import com.smartitengineering.dao.common.CommonReadDao;
+import com.smartitengineering.dao.common.CommonWriteDao;
+import com.smartitengineering.dao.common.queryparam.QueryParameter;
+import com.smartitengineering.dao.impl.hbase.spi.ObjectRowConverter;
+import com.smartitengineering.dao.impl.hbase.spi.SchemaInfoProvider;
+import com.smartitengineering.domain.PersistentDTO;
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.LinkedHashMap;
+import java.util.LinkedHashSet;
+import java.util.List;
+import java.util.Map;
+import java.util.Set;
+import org.apache.hadoop.conf.Configuration;
+import org.apache.hadoop.hbase.HBaseConfiguration;
+import org.apache.hadoop.hbase.client.Delete;
+import org.apache.hadoop.hbase.client.Get;
+import org.apache.hadoop.hbase.client.HTableInterface;
+import org.apache.hadoop.hbase.client.HTablePool;
+import org.apache.hadoop.hbase.client.Put;
+import org.apache.hadoop.hbase.client.Result;
+import org.apache.hadoop.hbase.util.Bytes;
+
+/**
+ *
+ * @author imyousuf
+ */
+public class AbstractCommonDao<Template extends PersistentDTO> implements CommonReadDao<Template>,
+                                                                          CommonWriteDao<Template> {
+
+  public static final int DEFAULT_MAX = 1000;
+  private ObjectRowConverter<Template> converter;
+  private SchemaInfoProvider infoProvider;
+  private Configuration configuration;
+  private HTablePool tablePool;
+
+  public ObjectRowConverter<Template> getConverter() {
+    return converter;
+  }
+
+  public void setConverter(ObjectRowConverter<Template> converter) {
+    this.converter = converter;
+  }
+
+  public SchemaInfoProvider getInfoProvider() {
+    return infoProvider;
+  }
+
+  public void setInfoProvider(SchemaInfoProvider infoProvider) {
+    this.infoProvider = infoProvider;
+  }
+
+  public Configuration getConfiguration() {
+    if (configuration == null) {
+      configuration = HBaseConfiguration.create();
+    }
+    return configuration;
+  }
+
+  public HTablePool getTablePool() {
+    if (tablePool == null) {
+      tablePool = new HTablePool(getConfiguration(), DEFAULT_MAX);
+    }
+    return tablePool;
+  }
+
+  /*
+   * READ OPERATIONS
+   */
+
+  /*
+   * Unsupported read operations
+   */
+  @Override
+  public Set<Template> getAll() {
+    throw new UnsupportedOperationException("Not supported yet.");
+  }
+
+  @Override
+  public <OtherTemplate> OtherTemplate getOther(List<QueryParameter> query) {
+    throw new UnsupportedOperationException("Not supported yet.");
+  }
+
+  @Override
+  public <OtherTemplate> List<OtherTemplate> getOtherList(List<QueryParameter> query) {
+    throw new UnsupportedOperationException("Not supported yet.");
+  }
+
+  /*
+   * Supported read operations
+   */
+  @Override
+  public Set<Template> getByIds(List<Integer> ids) {
+    LinkedHashSet<Template> set = new LinkedHashSet<Template>(ids.size());
+    for (Integer id : ids) {
+      set.add(getById(id));
+    }
+    return set;
+  }
+
+  @Override
+  public Template getById(Integer id) {
+    HTableInterface hTable = null;
+    try {
+      Get get = new Get(Bytes.toBytes(id));
+      hTable = getTablePool().getTable(infoProvider.getMainTableName());
+      Result result =
+             hTable.get(get);
+      return getConverter().rowsToObject(result);
+    }
+    catch (Exception ex) {
+      throw new RuntimeException(ex);
+    }
+    finally {
+      try {
+        if (hTable != null) {
+          getTablePool().putTable(hTable);
+        }
+      }
+      catch (Exception ex) {
+        ex.printStackTrace();
+      }
+    }
+  }
+
+  @Override
+  public Template getSingle(List<QueryParameter> query) {
+    throw new UnsupportedOperationException("Not supported yet.");
+  }
+
+  @Override
+  public List<Template> getList(List<QueryParameter> query) {
+    throw new UnsupportedOperationException("Not supported yet.");
+  }
+
+  @Override
+  public Template getSingle(QueryParameter... query) {
+    return getSingle(Arrays.asList(query));
+  }
+
+  @Override
+  public List<Template> getList(QueryParameter... query) {
+    return getList(Arrays.asList(query));
+  }
+
+  @Override
+  public <OtherTemplate> OtherTemplate getOther(QueryParameter... query) {
+    return this.<OtherTemplate>getOther(Arrays.asList(query));
+  }
+
+  @Override
+  public <OtherTemplate> List<OtherTemplate> getOtherList(QueryParameter... query) {
+    return this.<OtherTemplate>getOtherList(Arrays.asList(query));
+  }
+
+  /*
+   * WRITE OPERATIONS
+   */
+  @Override
+  public void save(Template... states) {
+    LinkedHashMap<String, List<Put>> allPuts = new LinkedHashMap<String, List<Put>>();
+    for (Template state : states) {
+      LinkedHashMap<String, Put> puts = getConverter().objectToRows(state);
+      for (Map.Entry<String, Put> put : puts.entrySet()) {
+        final List<Put> putList;
+        if (allPuts.containsKey(put.getKey())) {
+          putList = allPuts.get(put.getKey());
+        }
+        else {
+          putList = new ArrayList<Put>();
+          allPuts.put(put.getKey(), putList);
+        }
+        putList.add(put.getValue());
+      }
+    }
+    for (Map.Entry<String, List<Put>> puts : allPuts.entrySet()) {
+      HTableInterface hTable = null;
+      try {
+        hTable = getTablePool().getTable(puts.getKey());
+        hTable.put(puts.getValue());
+      }
+      catch (Exception ex) {
+        throw new RuntimeException(ex);
+      }
+      finally {
+        try {
+          if (hTable != null) {
+            getTablePool().putTable(hTable);
+          }
+        }
+        catch (Exception ex) {
+          ex.printStackTrace();
+        }
+      }
+    }
+  }
+
+  @Override
+  public void update(Template... states) {
+    save(states);
+  }
+
+  @Override
+  public void delete(Template... states) {
+    LinkedHashMap<String, List<Delete>> allPuts = new LinkedHashMap<String, List<Delete>>();
+    for (Template state : states) {
+      LinkedHashMap<String, Delete> puts = getConverter().objectToDeleteableRows(state);
+      for (Map.Entry<String, Delete> put : puts.entrySet()) {
+        final List<Delete> putList;
+        if (allPuts.containsKey(put.getKey())) {
+          putList = allPuts.get(put.getKey());
+        }
+        else {
+          putList = new ArrayList<Delete>();
+          allPuts.put(put.getKey(), putList);
+        }
+        putList.add(put.getValue());
+      }
+    }
+    for (Map.Entry<String, List<Delete>> puts : allPuts.entrySet()) {
+      HTableInterface hTable = null;
+      try {
+        hTable = getTablePool().getTable(puts.getKey());
+        hTable.delete(puts.getValue());
+      }
+      catch (Exception ex) {
+        throw new RuntimeException(ex);
+      }
+      finally {
+        try {
+          if (hTable != null) {
+            getTablePool().putTable(hTable);
+          }
+        }
+        catch (Exception ex) {
+          ex.printStackTrace();
+        }
+      }
+    }
+  }
+}
diff --git a/smart-hbase-dao/src/main/java/com/smartitengineering/dao/impl/hbase/App.java b/smart-hbase-dao/src/main/java/com/smartitengineering/dao/impl/hbase/App.java
deleted file mode 100644
index 1f49f91..0000000
--- a/smart-hbase-dao/src/main/java/com/smartitengineering/dao/impl/hbase/App.java
+++ /dev/null
@@ -1,13 +0,0 @@
-package com.smartitengineering.dao.impl.hbase;
-
-/**
- * Hello world!
- *
- */
-public class App 
-{
-    public static void main( String[] args )
-    {
-        System.out.println( "Hello World!" );
-    }
-}
-- 
2.11.4.GIT