0%

使用Python操作线上数据库脚本

前言

最近对于线上一些数据需要进行过滤导到本地来,或者对一些运营人员给的文本数据,需要在线上数据库跑出对应的结果出来,因此,需要通过一个脚本来执行。因为,现在服务器基本上会默认安装python,所以这里存一份脚本备用。

Python脚本

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30

#!/usr/bin/python
#coding=utf-8
import os;
import MySQLdb;
import sys;
reload(sys)
sys.setdefaultencoding('utf-8')
file=open("hotelseq.txt")
outfile=open("customer.txt",'w+')
conn=MySQLdb.connect(host='127.0.0.1',user='root',passwd='123456',db='test',port=3306,charset="utf8")
cur=conn.cursor()
order_cur = conn.cursor()

while 1:
line=file.readline().strip()
print line
if not line:
break
count=cur.execute("select cus.customer_state,cus.name from crm_customer_hotel as hotel join crm_customer as cus on hotel.customer_serial_number=cus.serial_number where hotel.hotel_seq='%s'" % line)
result = cur.fetchone()
print result
if result:
outfile.write(str(result[0])+" "+result[1])
outfile.write('\n')
cur.close()
file.close()
outfile.close()