您的位置：首页 > 脚本大全 > > 正文

python创建hbase命名空间（python使用phoenixdb操作hbase的方法示例）

更多 时间：2022-01-20 00:54:21 类别：脚本大全 浏览量：1141

python创建hbase命名空间

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 HBase phoenixdb
  • 上一篇：mysql里修改密码命令（MySQL修改账号密码方法大全小结）
  • 下一篇：mysql新增字段语句（关于Mysql update修改多个字段and的语法问题详析）
    • 您可能感兴趣
    首页 编程学习 Web前端 数据库 软件设计
    开心学习 ©2013-2021 保留所有权利