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']
最后运行这个程序看一下效果吧。
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持毛票票。