`

用Python操作Mysql

阅读更多
import MySQLdb
def insert_qs_data(table_name,time_num,data_value,data_type,cursor,conn):    
    cursor.execute("insert into "+table_name+"(time_num,data_value,data_type,insert_time) values("+str(time_num)+","+str(data_value)+",'"+data_type+"',now())")
    conn.commit()
    
def add_test_data(tag_name,table_name,url):
    conn = MySQLdb.connect(host='xxx.xxx.xxx.xxx', user='root',passwd='root')
    cursor = conn.cursor()
    conn.select_db('queryservicehistory')
    data_list=get_xml_data(tag_name,url)
    for index in range(len(data_list)-1):
        insert_qs_data(table_name,index+1,data_list[index],tag_name,cursor,conn)
    cursor.close()
    conn.close()
           
def truncate_table(table_name):
    conn = MySQLdb.connect(host='xxx,xxx,xxx,xxx', user='root',passwd='root')
    cursor = conn.cursor()
    conn.select_db('queryservicehistory')
    cursor.execute("truncate table "+table_name)
    conn.commit()
    cursor.close()
    conn.close()
    
def get_sql_data(sql):
    conn = MySQLdb.connect(host='xxx,xxx,xxx,xxx', user='root',passwd='root')
    cursor = conn.cursor()
    conn.select_db('queryservicehistory')
    cursor.execute(sql)
    result = cursor.fetchone()
    cursor.close()
    conn.close()
    return result
def get_sql_datas(sql):
    conn = MySQLdb.connect(host='xxx,xxx,xxx,xxx', user='root',passwd='root')
    cursor = conn.cursor()
    conn.select_db('queryservicehistory')
    cursor.execute(sql)
    cursor.scroll(0,mode='absolute')  
    results = cursor.fetchall()
    cursor.close()
    conn.close()
    return results
分享到:
评论

相关推荐

Global site tag (gtag.js) - Google Analytics