Advertisement
Guest User

Untitled

a guest
May 3rd, 2016
83
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 1.15 KB | None | 0 0
  1. import pyhs2
  2. with pyhs2.connect(host='localhost',
  3. port=10000,
  4. authMechanism="PLAIN",
  5. user='None',
  6. password='None',
  7. database='Default') as conn:
  8. with conn.cursor() as cur:
  9. #Show databases
  10. print cur.getDatabases()
  11.  
  12. #Execute query
  13. cur.execute("select * from table")
  14.  
  15. #Return column info from query
  16. print cur.getSchema()
  17.  
  18. #Fetch table results
  19. for i in cur.fetch():
  20. print i
  21.  
  22. Traceback (most recent call last):
  23. File "pyth_hive2.py", line 8, in <module>
  24. database='Default') as conn:
  25. File "build/bdist.linux-x86_64/egg/pyhs2/__init__.py", line 7, in connect
  26. File "build/bdist.linux-x86_64/egg/pyhs2/connections.py", line 46, in __init__
  27. File "build/bdist.linux-x86_64/egg/pyhs2/cloudera/thrift_sasl.py", line 74, in open
  28. File "build/bdist.linux-x86_64/egg/pyhs2/cloudera/thrift_sasl.py", line 92, in _recv_sasl_message
  29. File "build/bdist.linux-x86_64/egg/thrift/transport/TTransport.py", line 58, in readAll
  30. File "build/bdist.linux-x86_64/egg/thrift/transport/TSocket.py", line 94, in read
  31. thrift.transport.TTransport.TTransportException: None
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement