#工具庫導入import pandas as pdimport cx_Oracle# 注：設置環境編碼方式，可解決讀取數據庫亂碼問題import osos.environ['NLS_LANG'] = 'SIMPLIFIED CHINESE_CHINA.UTF8'#實現查詢并返回dataframedef query(table)  host = "127.0.0.1"  #數據庫ip  port = "1521"   #端口  sid = "test"  #數據庫名稱  dsn = cx_Oracle.makedsn(host, port, sid)  #scott是數據用戶名，tiger是登錄密碼（默認用戶名和密碼）  conn = cx_Oracle.connect("scott", "tiger", dsn)  #SQL語句，可以定制，實現靈活查詢  sql = 'select * from '+ table  # 使用pandas 的read_sql函數，可以直接將數據存放在dataframe中  results = pd.read_sql(sql,conn)  conn.close  return resultstest_data = query(test_table) # 可以得到結果集

#工具庫導入import pandas as pdimport cx_Oracle#實現插入功能def input_to_db(data,table):  host = "127.0.0.1"  #數據庫ip  port = "1521"   #端口  sid = "test"  #數據庫名稱  dsn = cx_Oracle.makedsn(host, port, sid)  #scott是數據用戶名，tiger是登錄密碼（默認用戶名和密碼）  conn = cx_Oracle.connect("scott", "tiger", dsn)  #建立游標  cursor = connection.cursor()  #sql語句,注意%s要加引號，否則會報ora-01036錯誤  query = "INSERT INTO"+table+"(name,gender,age) VALUES ('%s', '%s', '%s')"  #逐行插入數據  for i in range(len(data)):    name= data.ix[i,0]    gender= data.ix[i,1]    age= data.ix[i,2]   # 執行sql語句    cursor.execute（query % (name,gender,age))  connection.commit()  # 關閉游標  cursor.close()  connection.close()#測試插入數據庫#測試數據集test_data = pd.DataFrame([['小明','男',18],['小芳','女',18]],index = [1,2],columns=['name','gender','age'])#調用函數實現插入input_to_db(test_data,test_table1)

#!/usr/bin/python#coding=utf-8import threadingimport osimport time#用戶名user = 'username'#密碼passwd = 'password'#備份保存路徑savepath = '/home/oracle/orcl_bak/'#要備份的表tables = ' tables=department,employee'#備份周期circle = 2.0#備份命令global bak_commandbak_command = 'exp '+user+'/'+passwd + ' file=' + savepathdef orclBak():  now = time.strftime('%Y-%m-%d %H:%M:%S')  command = bak_command + now + '.dmp' + tables  print command  if os.system(command) == 0:    print '備份成功'  else:    print '備份失敗'  global t  t = threading.Timer(circle, orclBak)  t.start()t = threading.Timer(circle, orclBak)t.start()