通达信数据文件转成数据库

#!/usr/bin/env python
#coding: utf-8
#
import sys urllib urllib2 json thread threading datetime time
import MySQLdb as mysql

import os struct

class Stock（threading.Thread）:

    LAST = 19700101

    def __init__（selfmarket = None path = None prefix = None）:
        self.market = market
        self.path = path
        self.prefix = prefix
        self.codes = []
        self.daliy = []
        threading.Thread.__init__（self）

    #获取日线历史数据文件
    def get_stock_codes（self）:
        self.codes = [ f for f in os.listdir（self.path） if f.endswith（‘.day‘） and f.startswith（self.prefix）]


    def get_daliy_data（selfcode）:
        daliy = “{0}{1}“.format（self.pathcode）
        f = open（daliy‘rb‘）
        while 1:
            data = f.read（32）
            if data == ‘‘:
                break
        
            daliy_data = tuple（struct.unpack（‘iiiiifii‘data）） + （code[2:8]）
            #只有提取日期大于已保存的最大日期
            #print type（Stock.LAST） type（daliy_data[0]）
            if daliy_data[0] > Stock.LAST:
                self.daliy.append（daliy_data）  

    #获取已存取的最大日期
    #如果日期不存在返回默认值19700101
    @staticmethod
    def get_last_daliy（）:
        db = mysql.connect（host = ‘localhost‘ user = ‘root‘ passwd = ‘‘ db = ‘stock‘ charset=‘utf8‘）
        cursor = db.cursor（）
        try:
            sql = ‘‘‘SELECT MAX（st_date） FROM daliy‘‘‘
            cursor.execute（sql ）
            result = cursor.fetchone（）
            #print result
            Stock.LAST = 19700101 if result[0] == None else int（result[0].strftime（‘%Y%m%d‘））
        except:
            pass
        cursor.close（）
        db.close（）

    #st_date st_open st_high st_low st_close st_amount st_vol st_reservation = struct.unpack（‘iiiiifii‘data）    
    #print st_date code[2:8] float（st_open）/100 floa