summaryrefslogtreecommitdiffstats
path: root/collaboration/GSoC-2011-Eranda/hbase/src/main/java/org/apache/tuscany/nosqldatastore/hbase/HBaseDatatabase.java
diff options
context:
space:
mode:
authoreranda <eranda@13f79535-47bb-0310-9956-ffa450edef68>2011-07-09 09:02:32 +0000
committereranda <eranda@13f79535-47bb-0310-9956-ffa450edef68>2011-07-09 09:02:32 +0000
commit611747a6fea6b03c16d955af639d101319cf0b7f (patch)
tree314c6e820ba60d23fe00e9e44fad7cd5bf7c3fa9 /collaboration/GSoC-2011-Eranda/hbase/src/main/java/org/apache/tuscany/nosqldatastore/hbase/HBaseDatatabase.java
parent800d0da7d863cc75004b9e034646d457156edf97 (diff)
1. Remove static variable in SessionFactory
2. Set spaces to 4 3. Exception handling 4. Rename *Test to *TestCase 5. Convert test cases in to JUnit 6. Rename addValue() method in Group.java to addEntry() 7. Updated the addEntry method signature to accept String type only git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@1144620 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'collaboration/GSoC-2011-Eranda/hbase/src/main/java/org/apache/tuscany/nosqldatastore/hbase/HBaseDatatabase.java')
-rw-r--r--collaboration/GSoC-2011-Eranda/hbase/src/main/java/org/apache/tuscany/nosqldatastore/hbase/HBaseDatatabase.java37
1 files changed, 17 insertions, 20 deletions
diff --git a/collaboration/GSoC-2011-Eranda/hbase/src/main/java/org/apache/tuscany/nosqldatastore/hbase/HBaseDatatabase.java b/collaboration/GSoC-2011-Eranda/hbase/src/main/java/org/apache/tuscany/nosqldatastore/hbase/HBaseDatatabase.java
index 5d49fd76da..962a76eb5d 100644
--- a/collaboration/GSoC-2011-Eranda/hbase/src/main/java/org/apache/tuscany/nosqldatastore/hbase/HBaseDatatabase.java
+++ b/collaboration/GSoC-2011-Eranda/hbase/src/main/java/org/apache/tuscany/nosqldatastore/hbase/HBaseDatatabase.java
@@ -29,30 +29,27 @@ import org.apache.tuscany.nosqldatastore.Group;
import java.io.IOException;
public class HBaseDatatabase implements Database{
-
+
private HTable table;
private HBaseAdmin admin;
- HBaseDatatabase(String dbname, HBaseAdmin admin){
+ HBaseDatatabase(String dbname, HBaseAdmin admin) throws IOException {
Configuration conf = HBaseConfiguration.create();
- try {
- try{
- HTableDescriptor descriptor = new HTableDescriptor(dbname);
- admin.createTable(descriptor);
- } catch (MasterNotRunningException e) {
- e.printStackTrace();
- } catch (ZooKeeperConnectionException e) {
- e.printStackTrace();
- } catch (TableExistsException e){
- System.out.println("connected to existing database....");
- } finally {
- table = new HTable(conf,dbname);
- System.out.println(new String(table.getTableName()));
- this.admin = admin;
- table.flushCommits();
- }
- }catch (IOException ex) {
- ex.printStackTrace();
+
+ try{
+ HTableDescriptor descriptor = new HTableDescriptor(dbname);
+ admin.createTable(descriptor);
+ } catch (MasterNotRunningException e) {
+ e.printStackTrace();
+ } catch (ZooKeeperConnectionException e) {
+ e.printStackTrace();
+ } catch (TableExistsException e){
+ System.out.println("connected to existing database....");
+ } finally {
+ table = new HTable(conf,dbname);
+ System.out.println(new String(table.getTableName()));
+ this.admin = admin;
+ table.flushCommits();
}
}