Python连接phoenix的方法示例_Python

本文实例讲述了Python连接phoenix的方法。分享给大家供大家参考，具体如下：

phoenix是由saleforce.com开源的一个项目，后又捐给了Apache。它相当于一个Java中间件，帮助开发者，像使用jdbc访问关系型数据库一些，访问NoSql数据库HBase。可以把Phoenix只看成一种代替HBase的语法的一个工具。虽然可以用java可以用jdbc来连接phoenix，然后操作HBase，但是在生产环境中，不可以用在OLTP中。

Phoenix官网：http://phoenix.apache.org/

1.方案

这里我们通过Jpype和JayDeBeApi 来连接

2.过程

这里我列出实例代码：

									import jpype

									import jaydebeapi

									import os

									phoenix_client_jar="/data/users/huser/phoenix/phoenix-4.3.0-client.jar"

									args=='-Djava.class.path=%s'% phoenix_client_jar

									jvm_path=jpype.getDefaultJVMPath()

									jpype.startJVM(jvm_path,args)

									conn=jaydebeapi.connect('org.apache.phoenix.jdbc.PhoenixDriver',['jdbc:phoenix:bj-g2hdp1,bj-g2hdp2,bj-g2hdp3:2181','',''],phoenix_clinent_jar)

									curs=conn.cursor()

									sql="select * from test"

									count=curs.execute(sql)

									results=curs.fetchall()

									for r in results:

									  print r

希望本文所述对大家Python程序设计有所帮助。

原文链接：http://blog.csdn.net/taxueguilai1992/article/details/48970985

Python连接phoenix的方法示例

相关文章

热门资讯