python入门（八）：连接mysql和STMP详解编程语言

import pymysql 
 
def connect_mysql():                # 创建一个包含connect方法参数的函数 
    db_config = { 
        'host':'127.0.0.1', 
        'port':3306, 
        'user':'citizenwang', 
        'password':'yourpassword', 
        'db':'python', 
        'charset':'utf8mb4'        # charset 可以只写 utf8，注意不是 utf-8 
    } 
    try: 
        cms = pymysql.connect(**db_config)   # 创建一个 pymysql 链接对象，并赋值给 变量 cms 
    except Exception as e: 
        print(e) 
    return cms 
 
if __name__ == '__main__': 
    number = [] 
    for i in range(1,100): 
        number.append(i)                              # 创建一个包含 1 到 99 的列表 
    insert_sql = 'insert into test(id) value(%s);'    # 执行插入语句，将 number 插入列表 
    select_sql = 'select * from test;'                # 选择所有的表内容 
    db = connect_mysql()                              # 创建一个 PyMySQL 数据库链接对象 
    cus = db.cursor()                                 # 创建一个游标对象 
    try: 
        cus.execute('drop table if exists test; create table test(id int not null);')   # 执行语句，如果存在删除，并创建 
        cus.executemany(insert_sql, number)           # executemany(arg, para) 必须两个参数，第一个是 sql 语句，第二个是参数 
        cus.execute(select_sql)                       # execute(arg) 方法，执行 
 
        result1 = cus.fetchone()                      # fetchone()，选取一行内容输出 
        print('result1：', result1) 
 
        result2 = cus.fetchmany(4)                    # fetchmany(arg) 指定选取的行数 
        print('result2：', result2) 
 
        result3 = cus.fetchall()                      # fetchall() 从当前游标开始，读取所有行 
        print('result3：', result3) 
 
        cus.close()                                   # 关闭游标 
        db.commit()                                   # 提交数据库，如果没有这个操作，插入的数据就不会成功 
    except Exception as e: 
        db.rollback() 
        raise e 
    finally: 
        cus.close()