sqlalchemy-连接MySQL

笔记03：sqlalchemy增删改查

连接数据库

# -*- coding: utf-8 -*-

#import pymysql #没有用到pymysql，不过要安装这个库，不然会报错
from sqlalchemy import create_engine

host = 'localhost' #数据库地址
port = '3306' #端口
database = 'dd_db' #数据库名称
user = 'root' #数据库登陆账号
password = '' #登陆密码，没有密码就空字符串
'''
dd的格式：
数据库类型+数据库驱动名称://用户名:密码@机器地址:端口号/数据库名?字符编码
数据库：MySQL、postgresql、sqlite等，一律小写
数据库驱动：pymysql、MySQLdb
pymysql：支持python 3.x
MySQLdb：不支持python3.x
例如：mysql+pymysql://root:@localhost:3306/test_db?charset=utf8
charset=utf8：预防中文字符乱码
'''
dd = 'mysql+pymysql://{}:{}@{}:{}/{}?charset=utf8'.format(user,password,host,port,database)

print(dd)

engine = create_engine(dd)

with engine.connect() as con:
    con.execute('drop table if exists users')
#python中的三引号""""""能包含多行字符串，一般用于包括复杂的字符串，比如html或sql语句等
    con.execute("""create table users(id int primary key auto_increment,name varchar(25),age int, income float)""")
    con.execute("""insert into users(name,age,income) values('小卡卡',26,8755)""")
    con.execute("""insert into users(name,age,income) values('大阿',28,4671)""")
    rs = con.execute('select * from users')
    
    for row in rs:
        print(row)