Python多線程存取MySQL數據

這兩天正好接觸python對sql的多線程問題，於是寫了個demo以供參考。

首先安裝MySQLdb，指令是：pip install mysql-python

1.存入數據：

import MySQLdb
import datetime
import time
def insert(io):
    while True:
        time_now = datetime.datetime.now()
        print io,time_now
        conn = MySQLdb.connect(user = "root", passwd = "qwe123", host = "192.2.4.166", db = "python")
        cur = conn.cursor()
        sql = "insert into table_%s values ('%s','%s');"
        cur.execute(sql%(io,io,time_now))
        cur.close()
        conn.commit()
        time.sleep(5)

if __name__ == "__main__":
    import threading
    t = threading.Thread(target=insert,args=('in',))
    t.start()
    t = threading.Thread(target=insert,args=('out',))
    t.start()
    t.join()

2.讀取數據：

#coding *.* coding: utf-8 *.*
import MySQLdb
import time
conn = MySQLdb.connect(
    host = "192.2.4.166",
    port = 3306,
    user = "root",
    passwd = 'qwe123',
    db = 'python',
    #如果遇到數據庫中有中文，加這條
    charset = "utf8",
)
def read(io):
    list = [0]
    while True:
        conn = MySQLdb.connect(user="root", passwd="qwe123", host="192.2.4.166", db="python")
        # cursorclass 使輸出變為字典形式
        cur = conn.cursor(cursorclass=MySQLdb.cursors.DictCursor)
        sql = "select * from table_%s order by date desc;"
        cur.execute(sql % io)
        info = cur.fetchone()
        if info not in list:
            print info
            list.append(info)
            list.pop(0)
        cur.close()
        conn.commit()
        time.sleep(2)

if __name__ == "__main__":
    import threading
    t = threading.Thread(target=read, args=('in',))
    t.start()
    t = threading.Thread(target=read, args=('out',))
    t.start()
    t.join()