Mysql配置

修改配置文件: sudo vim /etc/mysql/my.cnf , 　避免插入數據時出現內存表is full的錯誤。
添加如下內容:

            
              [mysqld]
# 避免內存表if full, 自行設置
max_heap_table_size = 4096M

            
          

重啟mysql服務: sudo service mysql restart

創建數據表

創建一個商品數據表goods，
商品分類表和商品品牌表需要獨立建的，
這里添加到商品表里面，是為了測試分表
操作對查詢性能的影響，請忽視。

InnoDb引擎表

            
              DROP TABLE IF EXISTS goods;
CREATE TABLE goods
(
   goods_id INT(11) UNSIGNED NOT NULL AUTO_INCREMENT,
   goods_name VARCHAR(30) NOT NULL DEFAULT '' COMMENT '商品名稱',
   goods_price DECIMAL(10, 2) NOT NULL DEFAULT 0.0 COMMENT '商品價格',
   goods_cate VARCHAR(30) NOT NULL DEFAULT ''  COMMENT '商品分類名稱',
   goods_brand VARCHAR(30) NOT NULL DEFAULT '' COMMENT '商品品牌名稱',
   goods_order TINYINT(1) NOT NULL DEFAULT 0 COMMENT '排序字段',
   create_time INT(11) NOT NULL DEFaULT 0 COMMENT '創建時間',
   update_time INT(11) NOT NULL DEFaULT 0 COMMENT '更新時間',
   PRIMARY KEY(goods_id)
   # INDEX order_index (`goods_order`) 暫時不加索引，優化的時候再加， 測試性能差別
)ENGINE = INNODB AUTO_INCREMENT = 1 DEFAULT CHARSET = utf8 COMMENT '商品表';

            
          

Memory引擎表

            
              DROP TABLE IF EXISTS goods_memory;
CREATE TABLE goods_memory
(
   goods_id INT(11) UNSIGNED NOT NULL AUTO_INCREMENT,
   goods_name VARCHAR(30) NOT NULL DEFAULT '' COMMENT '商品名稱',
   goods_price DECIMAL(10, 2) NOT NULL DEFAULT 0.0 COMMENT '商品價格',
   goods_cate VARCHAR(30) NOT NULL DEFAULT ''  COMMENT '商品分類名稱',
   goods_brand VARCHAR(30) NOT NULL DEFAULT '' COMMENT '商品品牌名稱',
   goods_order TINYINT(1) NOT NULL DEFAULT 0 COMMENT '排序字段',
   create_time INT(11) NOT NULL DEFaULT 0 COMMENT '創建時間',
   update_time INT(11) NOT NULL DEFaULT 0 COMMENT '更新時間',
	 PRIMARY KEY(goods_id)
	 # INDEX order_index (goods_order) 暫時不加索引，優化的時候再加， 測試性能差別
)ENGINE = MEMORY AUTO_INCREMENT = 1 DEFAULT CHARSET = utf8 COMMENT '內存商品表';

            
          

創建存儲過程

使用存儲過程的插入速度較快，原因在與存儲過程預編譯并保存在數據庫中，而SQL運行過程需要經歷幾個階段。

            
              CREATE DEFINER=`root`@`localhost` PROCEDURE `add_goods`(
    IN g_name VARCHAR (30),
    IN g_price DECIMAL(10, 2),
    IN g_cate VARCHAR(30),
    IN g_brand VARCHAR(30),
    IN g_order TINYINT(1),
    IN c_time INT(11),
    IN u_time INT(11)
    )
BEGIN  
   INSERT INTO goods_memory(goods_name, goods_price, goods_cate, goods_brand, goods_order, create_time, update_time)
    VALUES( g_name, g_price, g_cate, g_brand, g_order, c_time, u_time);
END

            
          

該除了不能生孩子的Python上場了

            
              # _*_coding:utf-8_*_
"""
File: main.py
Time: 2019/8/20 21:07
Author: ClassmateLin
Email: 406728295@qq.com
Desc: 
"""
import asyncio
import aiomysql
import random
import decimal
import time

pool = ''


async def consumer(num: int):
    """
    生成數據，并調用存儲過程插入數據
    :param num: 需要生成的數據條數
    :return: 
    """
    brands = ['華為', '小米', '中興', '華碩', '戴爾', '三星', '金士頓', '耐克', '新百倫']
    categories = ['手機', '電腦', '配件', '箱包', '服飾', '鞋子', '家具']
    for i in range(num):
        async with pool.acquire() as conn:
            async with conn.cursor() as cur:
                try:
                    goods_name = '商品' + str(i)
                    goods_cate = random.choice(categories)
                    goods_brand = random.choice(brands)
                    goods_order = random.randint(0, 9)
                    goods_price = decimal.Decimal(random.randint(100, 1000000))
                    create_time = update_time = time.time()
                    # 調用存儲過程插入數據到內存表
                    await cur.callproc('add_goods', (goods_name, goods_price, goods_cate,
                                                     goods_brand, goods_order, create_time, update_time))
                    print('插入第{}條數據成功'.format(str(i)))
                except aiomysql.Error as e:
                    print('mysql error {}: {}'.format(e.args[0], e.args[1]))


async def main(loop, num):
    global pool
    database = {
        'host': '127.0.0.1',
        'port': 3306,
        'user': 'root',
        'password': 'root',
        'db': 'test',
        'loop': loop,
        'charset': 'utf8',
        'autocommit': True
    }
    pool = await aiomysql.create_pool(**database)
    asyncio.ensure_future(consumer(num))

if __name__ == '__main__':
    max_num = 10000 * 1000  # 1千萬
    loop = asyncio.get_event_loop()
    asyncio.ensure_future(main(loop, max_num))
    loop.run_forever()

            
          

內存表數據插入到普通表

內存表可能一次存不了1千萬, 測試大概需要6G內存左右
可以重復執行Python腳本，插入普通表和清空內存表步驟，內存夠大的請忽略。
INSERT INTO goods SELECT * FROM goods_memory

個人博客