相思资源网 Design By www.200059.com
今天看看怎样在 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']
最后运行这个程序看一下效果吧。
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。
相思资源网 Design By www.200059.com
广告合作：本站广告合作请联系QQ：858582 申请时备注：广告合作（否则不回）
免责声明：本站文章均来自网站采集或用户投稿，网站不提供任何软件下载或自行开发的软件！ 如有用户或公司发现本站内容信息存在侵权行为，请邮件告知！ 858582#qq.com
免责声明：本站文章均来自网站采集或用户投稿，网站不提供任何软件下载或自行开发的软件！ 如有用户或公司发现本站内容信息存在侵权行为，请邮件告知！ 858582#qq.com
相思资源网 Design By www.200059.com
暂无python使用phoenixdb操作hbase的方法示例的评论...