python如何使用phoenixdb操作hbase

這篇文章主要介紹python如何使用phoenixdb操作hbase，文中介紹的非常詳細(xì)，具有一定的參考價值，感興趣的小伙伴們一定要看完！

安裝 phoenixdb 庫

pip install phoenixdb

例子

首先啟動 queryserver 服務(wù)

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

然后使用下面代碼來建立連接、創(chuàng)建/刪除并查詢表。代碼比較簡單，和我們通常查詢關(guān)系型數(shù)據(jù)庫比較類似，這里就不多說了哈。

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如何使用phoenixdb操作hbase”這篇文章的所有內(nèi)容，感謝各位的閱讀！希望分享的內(nèi)容對大家有幫助，更多相關(guān)知識，歡迎關(guān)注億速云行業(yè)資訊頻道！