首页 > 数据库> 文章详细

Python：访问数据库

2021-04-13 09:06:07 阅读：135 来源： 互联网

标签：execute name Python 数据库 cursor 访问 session user conn

一、使用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基础笔记均是在廖雪峰的官方网站学习过程中记录的，仅作参考】

标签：execute,name,Python,数据库,cursor,访问,session,user,conn
来源： https://blog.csdn.net/m0_46967856/article/details/115618740

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

Python：访问数据库