1.引入pymssql包
import pymssql
2.建立连接:
conn = pymssql.connect(server=conf[‘db_address‘],
port="1433",user=conf[‘db_username‘],
password=conf[‘db_password‘],
database=conf[‘db_name‘],
charset="UTF-8")
cursor = conn.cursor()
3.执行SQL语句:
cursor.execute(sql)
4.获得数据:
search_table = cursor.fetchall()
5.修改数据:
cursor.execute(sql,(str(datetime.today()),))
conn.commit()
定义一个python的类
#tool class to write data into file
class OutFile:
dir_ = ‘‘
sew_ = ‘==‘
def __init__(self, dir, sew = ‘==‘):
self.dir_ = dir
self.sew_ = sew
def write_line(self, line, date):
fp = open(self.dir_ + "/" + date, ‘ab‘)
print line
fp.write(line)
fp.write(‘\n‘)
fp.close()
def write_vector(self, vec, date):
fp = open(self.dir_ + "/" + date, ‘ab‘)
if len(vec) > 0:
for i in range(0, len(vec) - 1):
fp.write(vec[i])
fp.write(self.sew_)
fp.write(vec[len(vec) - 1])
fp.write(‘\n‘)
fp.close()
def write_dict(self, dict, date):
fp = open(self.dir_ + "/" + date, ‘ab‘)
for key in dict:
fp.write(key)
fp.write(‘ : ‘)
leng = len(dict[key])
for i in range(0, leng - 1):
fp.write(dict[key][i])
fp.write(self.sew_)
fp.write(dict[key][leng - 1])
fp.write(‘\n‘)
fp.close()
def write_dict_dict(self, dict_dict, date):
fp = open(self.dir_ + "/" + date, ‘ab‘)
for key in dict_dict:
fp.write(key.encode(‘latin-1‘))
print key.encode(‘latin-1‘)
#fp.write(key.decode(‘utf-8‘).encode(‘gbk‘))
dict = dict_dict[key]
fp.write(self.sew_)
for key_word in dict:
#fp.write(key_word.decode(‘utf-8‘).encode