python3 各种方式连接mysql数据库

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
print("python连接mysql数据库")
# import mysql.connector
"""
#1 使用mysql-connector连接mysql
import mysql.connector

mydb = mysql.connector.connect(
    host="localhost",
    user="clever",
    passwd="1881301",
    database="clever"
)

mycursor = mydb.cursor()

mycursor.execute("show  databases")
print(mycursor.fetchall())
print(mydb)
"""

"""
# 2 使用pymysql连接mysql
import pymysql

# 打开数据库连接
db = pymysql.connect(host="localhost",
                     user="clever",
                     password="1881301",
                     database="clever")

# 使用 cursor() 方法创建一个游标对象 cursor
cursor = db.cursor()

# 使用 execute()  方法执行 SQL 查询
sql = "SELECT VERSION()"
cursor.execute(sql)

# 使用 fetchone() 方法获取单条数据.
data = cursor.fetchone()

print("Database version : %s " % data)

# 关闭数据库连接
db.close()
"""


"""
#3 使用SQLAlchemy


"""
from sqlalchemy import Column, String, create_engine
from sqlalchemy.orm import sessionmaker
from sqlalchemy.ext.declarative import declarative_base

# 创建对象的基类:
Base = declarative_base()

# 定义User对象:
class User(Base):
    # 表的名字:
    __tablename__ = 'user'

    # 表的结构:
    id = Column(String(20), primary_key=True)
    name = Column(String(20))


# 初始化数据库连接:
host="localhost"
user="clever"
password="1881301"
database="clever"
engine = create_engine('mysql+pymysql://{}:{}@{}:3306/{}'.format(user,password,host,database))
# 创建DBSession类型:
DBSession = sessionmaker(bind=engine)

# 添加一条记录
# 创建session对象:
session = DBSession()
# 建库
# session
# 创建新User对象:
new_user = User(id='5', name='Bob')
# 添加到session:
session.add(new_user)
# 提交即保存到数据库:
session.commit()
# 关闭session:
session.close()