python使用phoenixdb操作hbase的方法示例
今天看看怎样在python中使用phoenixdb来操作hbase
安装phoenixdb库
pipinstallphoenixdb
例子
首先启动queryserver服务
cdapache-phoenix-4.14.1-HBase-1.4-bin/bin ./queryserver.py
然后使用下面代码来建立连接、创建/删除并查询表。代码比较简单，和我们通常查询关系型数据库比较类似，这里就不多说了哈。
importphoenixdb
importphoenixdb.cursor
url='http://localhost:8765/'
conn=phoenixdb.connect(url,autocommit=True)
cursor=conn.cursor()
#cursor.execute("DROPTABLEusers")
cursor.execute("CREATETABLEusers(idINTEGERPRIMARYKEY,usernameVARCHAR,passwordVARCHAR)")
cursor.execute("UPSERTINTOusersVALUES(?,?,?)",(1,'admin','Letmein'))
cursor.execute("UPSERTINTOusersVALUES(?,?,?)",(2,'kongxx','Letmein'))
cursor.execute("SELECT*FROMusers")
printcursor.fetchall()
cursor=conn.cursor(cursor_factory=phoenixdb.cursor.DictCursor)
cursor.execute("SELECT*FROMusersWHEREid=1")
user=cursor.fetchone()
printuser['USERNAME']
printuser['PASSWORD']
最后运行这个程序看一下效果吧。
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。