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']
最后运行这个程序看一下效果吧。
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。
热门推荐
7 简短的二胎祝福语
10 简短霸气女儿生日 祝福语
11 祝福语高考小众诗句简短
12 元旦祝福语20秒简短
13 老师过年祝福语大全 简短
14 一生祝福语简短
15 产检祝福语简短霸气
16 朋友店开张祝福语简短
17 生日爱情祝福语大全简短
18 朋友女儿生日祝福语 简短