sqlalchemy-连接MySQL
连接数据库
# -*- 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)