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']
最后运行这个程序看一下效果吧。
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。
热门推荐
10 财运虎年祝福语简短语
11 单亲爸爸春节祝福语简短
12 狗狗上厕所训练
13 植物种植祝福语简短
14 翻译考试祝福语朋友简短
15 个人周年庆简短祝福语
16 狗狗怎么训练
17 分别祝福语简短搞笑英文
18 生日广州男生祝福语简短