一、使用SQLite
使用Cursor对象执行insert，update，delete语句时，执行结果由rowcount返回影响的行数，就可以拿到执行结果。

import os, sqlite3

db_file = os.path.join(os.path.dirname(__file__), 'test.db')
if os.path.isfile(db_file):
    os.remove(db_file)

# 连接到sqlite数据库，文件是file.db,文件不存在时会在当前目录创建:
conn = sqlite3.connect(db_file)
#打开游标cursor，通过cursor执行sql语句获得执行结果
cursor = conn.cursor()
#执行一条sql语句，创建user表
cursor.execute('create table user(id varchar(20) primary key, name varchar(20), score int)')
#继续执行sql语句，插入记录
cursor.execute(r"insert into user values ('A-001', 'Adam', 95)")
cursor.execute(r"insert into user values ('A-002', 'Bart', 62)")
cursor.execute(r"insert into user values ('A-003', 'Lisa', 78)")
#关闭cursor
cursor.close()
#提交事务：
conn.commit()
#关闭connection：
conn.close()

def get_score_in(low, high):
    ' 返回指定分数区间的名字，按分数从低到高排序 '
    conn1 = sqlite3.connect(db_file)
    cursor = conn1.cursor()
    #执行查询语句（sql对象执行select语句时，通过fetchall()可以拿到结果集

    #如果SQL语句带有参数，那么需要把参数按照位置传递给execute()方法，有几个?占位符就必须对应几个参数
    cursor.execute("select name from user where score >= ? and score <= ?  order by score asc;", (low, high,))
    #获得查询结果集
    values = cursor.fetchall()
    result = []
    for v in values:
        result.append(v[0])  # values返回的是一个列表，每一个元素都是一个tuple,对应一行记录。需要转换成list,元素是个字符窜型
    cursor.close()
    conn1.close()
    #搞清connection和cursor对象，打开后正确关闭，否则资源就会泄露
    return result
# 测试:
assert get_score_in(80, 95) == ['Adam'], get_score_in(80, 95)
assert get_score_in(60, 80) == ['Bart', 'Lisa'], get_score_in(60, 80)
assert get_score_in(60, 100) == ['Bart', 'Lisa', 'Adam'], get_score_in(60, 100)

print('Pass')

要确保出错的情况下也能关闭掉Connection对象和Cursor对象，需要使用try:…except:…finally:…

二、连接到SQL

# 导入MySQL驱动:
>>> import mysql.connector
# 注意把password设为你的root口令:
>>> conn = mysql.connector.connect(user='root', password='2333', database='test')
>>> cursor = conn.cursor()
# 创建user表:
>>> cursor.execute('create table user (id varchar(20) primary key, name varchar(20))')
# 插入一行记录，注意MySQL的占位符是%s:
>>> cursor.execute('insert into user (id, name) values (%s, %s)', ['1', 'Michael'])
>>> cursor.rowcount
1
# 提交事务:执行INSERT等操作后要调用commit()提交事务
>>> conn.commit()
>>> cursor.close()
# 运行查询:
>>> cursor = conn.cursor()
>>> cursor.execute('select * from user where id = %s', ('1',))
>>> values = cursor.fetchall()
>>> values
[('1', 'Michael')]
# 关闭Cursor和Connection:
>>> cursor.close()
True
>>> conn.close()

三、使用SQLAlchemy（还有一对多）
ORM框架的作用就是把数据库表的一行记录与一个对象互相做自动转换。

# 导入:
from sqlalchemy import Column, String, create_engine, ForeignKey
from sqlalchemy.orm import sessionmaker, relationship
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))

# 初始化数据库连接,连接信息：('数据库类型+数据库驱动名称://用户名:口令@机器地址:端口号/数据库名')
engine = create_engine('mysql+mysqlconnector://root:2333@localhost:3306/test')
# 创建DBSession类型:
DBSession = sessionmaker(bind=engine)
# 向数据库表添加一行记录，视为添加一个User对象：
# 创建session对象:
session = DBSession()
# 创建新User对象:
new_user = User(id='5', name='Bob')
# 添加到session:
session.add(new_user)
# 提交即保存到数据库:
session.commit()
# 关闭session:
session.close()

# DBSession对象可视为当前数据库连接
# 创建Session:
session = DBSession()
# 创建Query查询，filter是where条件，最后调用one()返回唯一行，如果调用all()则返回所有行:
user = session.query(User).filter(User.id=='5').all()
# 打印类型和对象的name属性:
print('type:', type(user))
print('name:', user.name)
# 关闭Session:
session.close()

【本博客中Python基础笔记均是在廖雪峰的官方网站学习过程中记录的，仅作参考】