Python安装jpype调用java，安装jaydebeapi通过jdbc连接数据库

pip install JPype1或下载JPype1-0.7.0.tar.gz包

经常出现需要安装VC++服务等

测试代码如下：

# Author: zfh
import jpype,os,time,timer
from jpype import java
from jpype import javax

HOST='192.168.48.103'
PORT=9999
USER=''
PASS=''

URL = "service:jmx:rmi:///jndi/rmi://%s:%d/jmxrmi" % (HOST, PORT)
print('URL-->',URL)
jvmPath = jpype.getDefaultJVMPath()
print('jvmPath-->',jvmPath)
#this it the path of your libjvm /usr/lib/jvm/sun-jdk-1.6/jre/lib/amd64/server/libjvm.so on linux
# jpype.startJVM("C:Program FilesJavajre1.8.0_191inserverjvm.dll")
if not jpype.isJVMStarted():
    jpype.startJVM(jvmPath)
jpype.java.lang.System.out.println('Hello world!')
# print(jpype.startJVM("C:Program FilesJavajre1.8.0_191inserverjvm.dll"))
jhash  = java.util.HashMap()
jarray = jpype.JArray(java.lang.String)([USER,PASS])
jhash.put(javax.management.remote.JMXConnector.CREDENTIALS, jarray);
jmxurl = javax.management.remote.JMXServiceURL(URL)
jmxsoc = javax.management.remote.JMXConnectorFactory.connect(jmxurl,jhash)
try:
    connection = jmxsoc.getMBeanServerConnection();
except Exception as e:
    print(e)
print('connection-->',connection)
#
#
while True:
    time.sleep(60)
    object="java.lang:type=Threading"
    attribute="ThreadCount"
    attr=connection.getAttribute(javax.management.ObjectName(object),attribute)
    print('ThreadCount-->',attribute, attr)
    #
    #Memory is a special case the answer is a Treemap in a CompositeDataSupport
    object="java.lang:type=Memory"
    attribute="HeapMemoryUsage"
    attr=connection.getAttribute(javax.management.ObjectName(object),attribute)
    print('HeapMemoryUsage-->',attr.contents.get("used"))
    #ceshi
    object="kafka.server:type=BrokerTopicMetrics,name=MessagesInPerSec"
    attribute="Count"
    attr=connection.getAttribute(javax.management.ObjectName(object),attribute)
    print('Count-->',attribute,attr)

    object="java.lang:type=OperatingSystem"
    attribute="Version"
    attr=connection.getAttribute(javax.management.ObjectName(object),attribute)
    print('Version-->',attribute,attr)

    object="kafka.server:type=ReplicaManager,name=PartitionCount"
    attribute="Value"
    attr=connection.getAttribute(javax.management.ObjectName(object),attribute)
    print('Value-->',attribute,attr)

运行结果如下：（记录一下jvmPath）

URL--> service:jmx:rmi:///jndi/rmi://192.168.48.103:9999/jmxrmi
jvmPath--> C:Program FilesJavajre1.8.0_211inserverjvm.dll
Hello world!
connection--> javax.management.remote.rmi.RMIConnector$RemoteMBeanServerConnection@531d72ca
ThreadCount--> ThreadCount 60
HeapMemoryUsage--> 156563848
Count--> Count 0
Version--> Version 2.6.32-431.el6.x86_64
Value--> Value 24

安装pip install JayDeBeApi 或下载JayDeBeApi-1.1.1.tar.gz(安装JayDeBeApi依赖JPype1)

# Author: zfh
import jaydebeapi
url = 'jdbc:oracle:thin:@192.168.48.102:1521/orcl'
user = 'scott'
password = 'scott'
dirver = 'oracle.jdbc.driver.OracleDriver'
jarFile = 'D:Program Files (x86)Pythonojdbc6.jar'
sqlStr = 'select * from emp'
# conn=jaydebeapi.connect('oracle.jdbc.driver.OracleDriver','jdbc:oracle:thin:@127.0.0.1:1521/orcl',['hwf_model','hwf_model'],'E:/pycharm/lib/ojdbc14.jar')
conn = jaydebeapi.connect(dirver, url, [user, password], jarFile)
curs = conn.cursor()
curs.execute(sqlStr)
result = curs.fetchall()
for row in result:
    print(row[0],row[1],row[2],row[3],row[4],row[5],row[6],row[7])
curs.close()
conn.close()