雪幕拉开，飘然而至分外美妙，初起便显现出意境；雪落十分，然间有种喜悦在心间荡漾，纷飞飘扬尽享每一刻青春的激情；飞舞的雪花，感受芬芳的韵味，迷人心脾围绕在身旁；耳畔，时常想有沙沙的声音那样的动听，百听不厌，着迷在这一刻升起动人心怀的旋律。
今天看看怎样在 python 中使用 phoenixdb 来操作 hbase
安装 phoenixdb 库
pip install phoenixdb
例子
首先启动 queryserver 服务
cd apache-phoenix-4.14.1-HBase-1.4-bin/bin ./queryserver.py
然后使用下面代码来建立连接、创建/删除并查询表。代码比较简单，和我们通常查询关系型数据库比较类似，这里就不多说了哈。
import phoenixdb
import phoenixdb.cursor
url = 'http://localhost:8765/'
conn = phoenixdb.connect(url, autocommit=True)
cursor = conn.cursor()
# cursor.execute("DROP TABLE users")
cursor.execute("CREATE TABLE users (id INTEGER PRIMARY KEY, username VARCHAR, password VARCHAR)")
cursor.execute("UPSERT INTO users VALUES (?, ?, ?)", (1, 'admin', 'Letmein'))
cursor.execute("UPSERT INTO users VALUES (?, ?, ?)", (2, 'kongxx', 'Letmein'))
cursor.execute("SELECT * FROM users")
print cursor.fetchall()
cursor = conn.cursor(cursor_factory=phoenixdb.cursor.DictCursor)
cursor.execute("SELECT * FROM users WHERE id=1")
user = cursor.fetchone()
print user['USERNAME']
print user['PASSWORD']
最后运行这个程序看一下效果吧。
以上就是python使用phoenixdb操作hbase的方法示例。生命中，那些我们真正想要的东西，从来得之不易。更多关于python使用phoenixdb操作hbase的方法示例请关注haodaima.com其它相关文章！
