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']
最后运行这个程序看一下效果吧。
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持脚本之家。
相关文章
今天小编就为大家分享一篇PyQt 实现使窗口中的元素跟随窗口大小的变化而变化，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧2019-06-06
这篇文章主要介绍了python 求两个向量的顺时针夹角操作，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧2021-03-03
这篇文章主要介绍了python实现杨辉三角的几种方法代码实例,文中图文代码讲解的很清晰，有不太懂的同学可以学习下2021-03-03
在Python中可以使用paramiko模块中的sftp登陆远程主机，实现上传和下载功能。接下来通过本文给大家介绍Python使用sftp实现上传和下载功能，需要的朋友参考下2017-03-03
下面小编就为大家分享一篇pandas按若干个列的组合条件筛选数据的方法，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧2018-04-04
本文主要介绍了pandas中pd.groupby()的用法详解，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧<BR>2022-06-06
这篇文章主要介绍了Python实现粒子群算法的示例，帮助大家更好的理解和使用Python，感兴趣的朋友可以了解下2021-02-02
本篇文章主要介绍了CentOS7.3编译安装Python3.6.2的方法，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧2018-01-01
这篇文章主要介绍了Python数据操作方法封装类,结合具体实例形式分析了Python针对数据库的连接、执行sql语句、删除、关闭等操作技巧,需要的朋友可以参考下2017-06-06
这篇文章主要介绍了python 并发编程 阻塞IO模型原理解析,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下2019-08-08
最新评论