-
Notifications
You must be signed in to change notification settings - Fork 1
/
huxianhua.py
73 lines (50 loc) · 1.75 KB
/
huxianhua.py
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
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
# -*- coding: cp936-*-
import MySQLdb
import datetime
import urllib
import re
from datetime import datetime,timedelta
# 建立一个连结
Con = MySQLdb.connect(host="192.168.116.20", port=3380, user= "lixueshi", passwd= "i14p4Dkyd", db= "house_report")
# 生成一个cursor, 用来执行sql语句
Cursor = Con.cursor( )
def init():
# 建立一个连结
global Cursor,companylist,hzyfdic
#每次清空 临时文件夹
sql = 'DELETE FROM koubeitemp'
#print sql
Cursor.execute(sql)
#每次先清空当天的口碑,然后再往里录入新口碑
sql = 'DELETE FROM koubei where date="'+str(datetime.today())[:10]+'"'
Cursor.execute(sql)
#把wrapper放到列表里
sql = 'SELECT DISTINCT(company) FROM wrapperCompany'
#print sql
Cursor.execute(sql)
Results = Cursor.fetchall( )
for r in Results:
m = r[0].decode('utf-8').encode('cp936')
companylist.append(m)
#把wrapper放到列表里
sql = 'SELECT * FROM koubei_hzyf'
#INSERT INTO koubei_hzyf (company,months) VALUES ('天泰航空',13)
#sql = 'insert into koubei_hzyf (company,months) VALUES ("天泰航空",12)'
#print sql
Cursor.execute(sql)
Results = Cursor.fetchall( )
for r in Results:
m = r[0].decode('utf-8').encode('cp936')
#print m,r[1]
hzyfdic[m] = r[1]
def main():
global Cursor
sql = "SELECT * FROM house_company_report_2012_07 LIMIT 10;"
Cursor.execute(sql)
# Fetch all results from the cursor into a sequence and close the connection
# 取得返回的值并关闭连接
Results = Cursor.fetchall( )
for r in Results:
print r
if __name__ == '__main__':
main()