diff options
author | eranda <eranda@13f79535-47bb-0310-9956-ffa450edef68> | 2011-07-09 09:02:32 +0000 |
---|---|---|
committer | eranda <eranda@13f79535-47bb-0310-9956-ffa450edef68> | 2011-07-09 09:02:32 +0000 |
commit | 611747a6fea6b03c16d955af639d101319cf0b7f (patch) | |
tree | 314c6e820ba60d23fe00e9e44fad7cd5bf7c3fa9 /collaboration/GSoC-2011-Eranda/hbase/src/main/java/org/apache/tuscany/nosqldatastore/hbase/HBaseDatatabase.java | |
parent | 800d0da7d863cc75004b9e034646d457156edf97 (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.java | 37 |
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(); } } |