import sys
sys.path.append('./gen-py')

from datahub import DataHub
from datahub.constants import *
from thrift import Thrift
from thrift.protocol import TBinaryProtocol
from thrift.transport import TSocket
from thrift.transport import TTransport

'''
@author: anant bhardwaj
@date: Oct 9, 2013

DataHub Client (Python)
'''

class DataHubClient:
  def __init__(self, host, port):
    try:
      transport = TSocket.TSocket(host, port)
      self.transport = TTransport.TBufferedTransport(transport)
      protocol = TBinaryProtocol.TBinaryProtocol(self.transport)
      self.client = DataHub.Client(protocol)
    except Thrift.TException, tex:
      print '%s' % (tex.message)

  def get_version(self):
    self.transport.open()
    version = self.client.get_version()
    self.transport.close()
    return version

  def connect(self, con_params):
    self.transport.open()
    con = self.client.connect(con_params)
    self.transport.close()
    return con

  def list_repos(self, con):
    self.transport.open()
    res = self.client.list_databases(con)
    self.transport.close()
    return res

  def list_tables(self, con):
    self.transport.open()
    res = self.client.list_tables(con)
    self.transport.close()
    return res

  def execute_sql(self, con, query, query_params=None):
    self.transport.open()
    res = self.client.execute_sql(con, query, query_params)
    self.transport.close()
    return res

  def load(self, con, url):
    self.transport.open()
    res = self.client.load(con, url)
    self.transport.close()
    return res


def test():
  client = DataHubClient(host='datahub-experimental.csail.mit.edu', port=9000)
  print client.get_version()
  con_params = DHConnectionParams(user='postgres', password='postgres')
  con = client.connect(con_params=con_params)
  print client.list_repos(con=con)

  try:
    print client.execute_sql(con=con, query=''' drop schema test ''')
    print client.list_databases(con=con)
  except Exception, e:
    print e.message

  print client.execute_sql(con=con, query=''' create schema test ''')
  print client.list_databases(con=con)

  con_params.repo = 'test'
  con = client.connect(con_params=con_params)

  print client.list_tables(con=con)
  print client.execute_sql(con=con,
      query=''' create table person (id integer, name varchar(20)) ''')
  print client.list_tables(con=con)
  print client.execute_sql(con=con, query=''' select * from person ''')
  print client.execute_sql(con=con,
      query=''' insert into person values (1, 'anant') ''')
  print client.execute_sql(con=con, query=''' select * from person ''')

if __name__ == '__main__':
  test()

@@ -1112,32 +1112,38 @@
 tables(self, con
+, repo
 ):%0A    self.tran
@@ -1188,24 +1188,30 @@
 t_tables(con
+, repo
 )%0A    self.t
@@ -2113,82 +2113,8 @@
 n)%0A%0A
-  con_params.repo = 'test'%0A  con = client.connect(con_params=con_params)%0A%0A
   pr
@@ -2135,32 +2135,45 @@
 t_tables(con=con
+, repo='test'
 )%0A  print client
@@ -2296,24 +2296,37 @@
 bles(con=con
+, repo='test'
 )%0A  print cl

make a namespace based access