1、连接oracle数据库:
#encoding: utf- 8
from sqlalchemy. ext. sqlsoup import SqlSoup
from sqlalchemy import create_engine
"" "连接数据库" ""
db_data = create_engine( 'oracle://username:password@xxx.xxx.xxx.xxx:1521/logpub' , pool_recycle= 60)
db = SqlSoup( db_data)
"" "查询数据" ""
sql = "select t.user_name,t.channel_name,t.channel_id,t.local_path from PUB_URL t where t.content_date = to_date('2015-02-26','yyyy-mm-dd') and t.local_path like '%%/data/Data%%'"
channels_massage = db. connection( ) . execute( sql) . fetchall( )
db. session. close( )
2、连接mysql数据库:
import MySQLdb
conn_athena = MySQLdb. connect( host= "192.168.xx.xx" , user= 'xxx' , passwd= 'xxxx' , db= 'xxx' )
cursor_athena = conn_athena. cursor( )
sql = "update hadoop_jobs t set t.status = 0"
cursor_athena. execute( sql)
cursor_athena.commit()
cursor_athena. close( )
conn_athena . close ( )
3、连接redis数据库:
import redis
r = redis. Redis( host= ip, port= port, password= pwd, db= db)
keys = r. keys( )
print keys
仅用于个人总结,仅供参考!
运维网声明
1、欢迎大家加入本站运维交流群:群②:261659950 群⑤:202807635 群⑦870801961 群⑧679858003
2、本站所有主题由该帖子作者发表,该帖子作者与运维网 享有帖子相关版权
3、所有作品的著作权均归原作者享有,请您和我们一样尊重他人的著作权等合法权益。如果您对作品感到满意,请购买正版
4、禁止制作、复制、发布和传播具有反动、淫秽、色情、暴力、凶杀等内容的信息,一经发现立即删除。若您因此触犯法律,一切后果自负,我们对此不承担任何责任
5、所有资源均系网友上传或者通过网络收集,我们仅提供一个展示、介绍、观摩学习的平台,我们不对其内容的准确性、可靠性、正当性、安全性、合法性等负责,亦不承担任何法律责任
6、所有作品仅供您个人学习、研究或欣赏,不得用于商业或者其他用途,否则,一切后果均由您自己承担,我们对此不承担任何法律责任
7、如涉及侵犯版权等问题,请您及时通知我们,我们将立即采取措施予以解决
8、联系人Email:admin@iyunv.com 网址:www.yunweiku.com