# -*- coding:utf-8 -*-
import time
from pymysql import *

# 裝飾器，計(jì)算插入50000條數(shù)據(jù)需要的時(shí)間
def timer(func):
    def decor(*args):
        start_time = time.time()
        func(*args)
        end_time = time.time()
        d_time = end_time - start_time
        print("the running time is : ", d_time)

    return decor

@timer
def add_test_users():

    conn = connect(host='主機(jī)名', port='端口號(hào)', user='用戶名', password='密碼', database='數(shù)據(jù)庫名', charset='utf8')
    cs = conn.cursor()　　?！～@取游標(biāo)
    for num in range(0, 58000):
        try:
            sql = "insert into '表名'(字段名) values(值)"
            cs.execute(sql)

        except Exception as e:
            return
            
    conn.commit()　?。！√峤?
    cs.close()
    conn.close()
    print('OK')

add_test_users()

# -*- coding:utf-8 -*-
import time
from pymysql import *

# 裝飾器，計(jì)算插入50000條數(shù)據(jù)需要的時(shí)間
def timer(func):
    def decor(*args):
        start_time = time.time()
        func(*args)
        end_time = time.time()
        d_time = end_time - start_time
        print("the running time is : ", d_time)

    return decor

@timer
def add_test_users():
    
    usersvalues = []
    for num in range(1, 50000):
        usersvalues.append(('需要插入的字段對(duì)應(yīng)的value'))  # 注意要用兩個(gè)括號(hào)擴(kuò)起來

    conn = connect(host='主機(jī)名', port='端口號(hào)', user='用戶名', password='密碼', database='數(shù)據(jù)庫名', charset='utf8')
    cs = conn.cursor()  # 獲取光標(biāo)
    # 注意這里使用的是executemany而不是execute，下邊有對(duì)executemany的詳細(xì)說明
    cs.executemany('insert into '表名'(字段名) values(%s,%s,%s,%s)', usersvalues)

    conn.commit()
    cs.close()
    conn.close()
    print('OK')

add_test_users()

executemany的用法：

import pymysql
list_1 = [('a',1),('b',2),(None,3)]  # 元素是不是元組都可以
sql_1 = 'insert into 表明(字段1,字段2) values(%s,%s)' 
# 注意，這里的%s不需要加引號(hào)，使用execute需要加引號(hào)。
# 另外，executemany 在執(zhí)行過程中能夠?qū)ython的None轉(zhuǎn)為sql的null
db = pymysql.connect(host= ....)
cursor = db.cursor()
cursor.executemany(sql_1,list_1)
db.commit()
cursor.close()
db.close()
print('完成')

import pymysql
conn = pymysql.connect(
    host='XXX.XXX.XXX.XXX', 
    user='XXXXX', 
    password='XXXXX', 
    db='XXXXX', 
    port=3306, 
    charset='utf8',
    autocommit = 1 ,
    )
 
# 集中大批量操作數(shù)據(jù)
 
import pymysql
conn = pymysql.connect(
    host='XXX.XXX.XXX.XXX', 
    user='XXXXX', 
    password='XXXXX', 
    db='XXXXX', 
    port=3306, 
    charset='utf8',
    )
 
SQl相關(guān)操作略
 
conn.commit()  # 提交