mysql.py 文件源码

def insert_feature_data(self, database_name, data, id):
        if isinstance(data, np.ndarray):
            pass
        if isinstance(data, pd.DataFrame):
            data = data.values
        if data.shape[0] == 0:
            return None

        sql_line = '''insert into %s values('{id}', '{date}', {data} )''' % (database_name, )
        for d in data:
            try:
                data_str = ','.join([str(x) for x in d[1:]])
                line = sql_line.format(id=id, date=d[0], data=data_str)
                self.cur.execute(line)
                # self.cur.close()
                # self.cur = self.db.cursor()
            except MySQLdb.Error as e:
                print 'fuck'
        self.db.commit()