gpt4 book ai didi

python使用phoenixdb操作hbase的方法示例

转载 作者:qq735679552 更新时间:2022-09-28 22:32:09 27 4
gpt4 key购买 nike

CFSDN坚持开源创造价值,我们致力于搭建一个资源共享平台,让每一个IT人在这里找到属于你的精彩世界.

这篇CFSDN的博客文章python使用phoenixdb操作hbase的方法示例由作者收集整理,如果你对这篇文章有兴趣,记得点赞哟.

今天看看怎样在 python 中使用 phoenixdb 来操作 hbase 。

安装 phoenixdb 库 。

?
1
pip install phoenixdb

例子 。

首先启动 queryserver 服务 。

?
1
2
cd apache-phoenix-4.14.1-HBase-1.4-bin /bin
. /queryserver .py

然后使用下面代码来建立连接、创建/删除并查询表。代码比较简单,和我们通常查询关系型数据库比较类似,这里就不多说了哈.

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
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' ]

最后运行这个程序看一下效果吧.

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持我.

原文链接:https://blog.csdn.net/kongxx/article/details/87996521 。

最后此篇关于python使用phoenixdb操作hbase的方法示例的文章就讲到这里了,如果你想了解更多关于python使用phoenixdb操作hbase的方法示例的内容请搜索CFSDN的文章或继续浏览相关文章,希望大家以后支持我的博客! 。

27 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com