python使用phoenixdb操作hbase的方法示例
2019-03-28 10:58
483 查看
今天看看怎样在 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使用pymongo模块操作MongoDB的方法示例
- Python yield使用方法示例
- 使用python删除nginx缓存文件示例(python文件操作)
- Python3学习urllib的使用方法示例
- 忘记ftp密码使用python ftplib库暴力破解密码的方法示例
- 在Python中操作时间之mktime()方法的使用教程
- 关于javascript里面仿python切片操作数组的使用方法
- python中pandas库中DataFrame对行和列的操作使用方法
- 使用python删除nginx缓存文件示例(python文件操作)
- 在Python中操作列表之List.append()方法的使用
- 在Python中操作字典之update()方法的使用
- 在Python中操作文件之seek()方法的使用教程
- Python使用xlrd模块操作Excel数据导入的方法
- Python简单操作sqlite3的方法示例
- python中关于操作时间的方法(一):使用time模块
- Memcached 安装、使用(Python操作)以及常用方法
- 用Python操作字符串之rindex()方法的使用
- 用Python操作字符串之rindex()方法的使用
- 在Python中操作字典之fromkeys()方法的使用
- 在Python中操作时间之strptime()方法的使用