python使用phoenixdb操作hbase的方法示例
更新时间：2019年02月28日 11:55:24 作者：kongxx
这篇文章主要介绍了python使用phoenixdb操作hbase的方法示例，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
今天看看怎样在 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']
最后运行这个程序看一下效果吧。
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持脚本之家。
相关文章
这篇文章主要介绍了Python3 ffmpeg视频转换工具使用方法解析,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下2020-08-08
在写代码的时候，往往会漏掉日志这个关键因素，导致功能在使用的时候出错却无法溯源。这个时候只要利用日志装饰器就能解决，本文将用Python自制一个简单实用的日志装饰器，需要的可以参考一下2022-05-05
今天小编就为大家分享一篇pytorch模型预测结果与ndarray互转方式，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧2020-01-01
今天小编就为大家分享一篇Python根据欧拉角求旋转矩阵的实例，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧2019-01-01
这篇文章主要介绍了UI自动化定位常用实现方法代码示例,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下2020-10-10
这篇文章主要介绍了Django框架实现的普通登录案例,结合实例形式分析了Django框架使用POST方法进行页面登录、校验等相关操作技巧,需要的朋友可以参考下2019-05-05
这篇文章主要介绍了python中enumerate函数用法,以实例形式较为详细的分析了enumerate函数的功能、定义及使用技巧,需要的朋友可以参考下2015-05-05
这篇文章主要介绍了django中的*args 与 **kwargs使用介绍，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧2021-03-03
RabbitMQ是一个在AMQP基础上完整的，可复用的企业消息系统。他遵循Mozilla Public License开源协议。下面这篇文章主要给大家介绍了关于利用Python操作消息队列RabbitMQ的方法教程，需要的朋友可以参考下。2017-07-07
这篇文章主要介绍了关于DataFrame中某列值的替换map(dict),具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教2024-02-02
最新评论