zhbvictor 2011-05-08
import os,sys
importcx_Oracle
defsearch(sqlstr,**argv):
cursor.execute(sqlstr,argv)
returncursor.fetchall()
defgetcols(tabname):
cols=search('selectcolumn_namefromuser_tab_columnswheretable_name=:V1orderbycolumn_id',V1=tabname)
s=''
forcolincols:
s=s+','+col[0]
returns[1:]
if__name__=='__main__':
ifsys.argv.__len__()!=3:
print"""PleaseInputConnectArgumentsAndSQLExportDirectory.\nEx:oracle_export.pyaa/bb@testdbe:\sqlfile"""
exit(-1)
desdir=sys.argv[2].
ifnotos.path.isdir(desdir):
print"TargetdirectoryisnotExists."
exit(-3)
try:
conn=cx_Oracle.Connection(sys.argv[1].split('/')[0],sys.argv[1].split('/')[1].split('@')[0],sys.argv[1].split('@')[-1])
exceptcx_Oracle.DatabaseError,strerr:
print"ConnectDataBaseFailure.\n%s"%strerr
exit(-2)
cursor=conn.cursor()
objs=search('selectdistincttype,namefromuser_source')
forobjinobjs:
f=open(os.path.join(desdir,obj[0].replace('','_')+''+obj[1])+'.sql','w')
str=search('selecttextfromuser_sourcewherename=:v1andtype=:v2orderbyline',V1=obj[1],V2=obj[0])
f.write('CREATEORREPLACE\n')
foriinstr:
f.write(i[0])
f.write('/\n')
f.close()
objs=search('selectview_name,textfromuser_views')
forobjinobjs:
f=open(os.path.join(desdir,'VIEW'+obj[0])+'.sql','w')
f.write('CREATEORREPLACE\n')
f.write('VIEW('+getcols(obj[0])+')AS\n')
f.write(obj[1])
f.write('/\n')
f.close()
cursor.close()
conn.close()
echo 1. 使用当前日期命名备份文件。echo 2. 自动删除7天前的备份。forfiles /p "%LOGDIR%" /s /m *.* /d -7 /c "cmd /c del @path"