summaryrefslogtreecommitdiffstats
path: root/collaboration/GSoC-2011-Eranda/hbase/src/main/java/org/apache/tuscany/nosqldatastore/hbase/HBaseDatatabase.java
diff options
context:
space:
mode:
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();
}
}