您当前的位置:首页 > 电脑百科 > 程序开发 > 语言 > Python

「Python」连接数据库的三种方式

时间:2020-06-19 11:31:27  来源:  作者:
「Python」连接数据库的三种方式

 

连接SQLite

要操作关系数据库,首先需要连接到数据库,一个数据库连接称为Connection;

连接到数据库后,需要打开游标,称之为Cursor,通过Cursor执行SQL语句,然后,获得执行结果。

Python定义了一套操作数据库的API接口,任何数据库要连接到Python,只需要提供符合Python标准的数据库驱动即可。

由于SQLite的驱动内置在Python标准库中,可以直接来操作SQLite数据库。

# 导入SQLite驱动:

import sqlite3

# 连接到SQLite数据库
# 数据库文件是test.db
# 如果文件不存在,会自动在当前目录创建:
conn = sqlite3.connect('test.db')

# 创建一个Cursor:
cursor = conn.cursor()

# 执行一条SQL语句,创建user表:
cursor.execute('create table user (id varchar(20) primary key, name varchar(20))')

# 继续执行一条SQL语句,插入一条记录:
cursor.execute('insert into user (id, name) values ("1", "vigilr")')

# 通过rowcount获得插入的行数:
count=cursor.rowcount

# 关闭Cursor:
cursor.close()

# 提交事务:
conn.commit()

# 关闭Connection:
conn.close()

查询数据库数据

conn = sqlite3.connect('test.db')
cursor = conn.cursor()

# 执行查询语句:
cursor.execute('select * from user where id=?',('1',))

# 获得查询结果集:
values = cursor.fetchall()

cursor.close()
conn.close()

使用Python的DB-API时,只要搞清楚`Connection`和`Cursor`对象,打开后一定记得关闭,就可以放心地使用。

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

使用`Cursor`对象执行`select`语句时,通过`featchall()`可以拿到结果集。结果集是一个`list`,每个元素都是一个`tuple`,对应一行记录。

如果SQL语句带有参数,那么需要把参数按照位置传递给`execute()`方法,有几个?占位符就必须对应几个参数,例如:

cursor.execute('select * from user where name=? and pwd=?', ('abc', 'password'))
# -*- coding: utf-8 -*-
import sqlite3
# 初始数据:
conn = sqlite3.connect('test1.db')
cursor = conn.cursor()
cursor.execute('create table user(id varchar(20) primary key, name varchar(20), score int)')
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.close()
conn.commit()
conn.close()

def get_score_in(low, high):
      '''返回指定分数区间的名字,按分数从低到高排序'''
      conn = sqlite3.connect('test1.db')
      cursor = conn.cursor()
      cursor.execute('select name from user where score>=? and score<=? ORDER BY score',(low,high))
      temp=cursor.fetchall()
      result=[]
      for t in temp:
      for i in t:
      result.Append(i)
      cursor.close()
      conn.close()
      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')

连接MySQL

安装MySQL驱动

由于MySQL服务器以独立的进程运行,并通过网络对外服务,所以,需要支持Python的MySQL驱动来连接到MySQL服务器。

MySQL官方提供了‘mysql-connector-python’驱动,但是安装的时候需要给pip命令加上参数‘--allow-external’:

pip install mysql-connector-python --allow-external mysql-connector-python

如果上面的命令安装失败,可以试试另一个驱动:

‘pip install mysql-connector’

除了使用`mysql.connector`还可以使用`pymysql`

# 导入pymysql模块
import pymysql

# 连接database
conn = pymysql.connect(host="127.0.0.1",port=3308,user="root",password="123456",database="test",charset="utf8")
cursor = conn.cursor()

# 创建user表:
cursor.execute('create table user (id varchar(20) primary key, name varchar(20))')

cursor.close()
conn.close()

# 连接database
conn = pymysql.connect(host="127.0.0.1",port=3308,user="root",password="123456",database="test",charset="utf8")
cursor = conn.cursor()

# 插入一行记录,注意MySQL的占位符是%s:
cursor.execute('insert into user (id, name) values (%s, %s)', ['1', 'wasd'])
cursor.execute('insert into user (id, name) values (%s, %s)', ['2', 'zxc'])
print('受影响行数:',cursor.rowcount)
# 提交事务:
conn.commit()
cursor.close()
conn.close()

使用SQLAlchemy

ORM技术:Object-Relational Mapping,把关系数据库的表结构映射到对象上。

在Python中,最有名的ORM框架是SQLAlchemy。

首先通过pip安装SQLAlchemy:`pip install sqlalchemy`

# 第一步,导入SQLAlchemy,并初始化DBSession:

# 导入:
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__ = 'users'
      # 表的结构:
      id = Column(String(20), primary_key=True)
      name = Column(String(20))

# 以上代码完成SQLAlchemy的初始化和具体每个表的class定义。如果有多个表,
# 就继续定义其他class,例如Scho
class School(Base):
      __tablename__ = 'school'
      id = Column(String(20), primary_key=True)
      name = Column(String(20))

# 初始化数据库连接:mysqlconnector和pymysql都可以用
# engine = create_engine('mysql+mysqlconnector://root:123456@localhost:3308/test')
engine = create_engine('mysql+pymysql://root:123456@localhost:3308/test')

# 创建DBSession类型:
DBSession = sessionmaker(bind=engine)

create_engine()用来初始化数据库连接。SQLAlchemy用一个字符串表示连接信息:

`数据库类型+数据库驱动名称://用户名:密码@数据库地址:端口号/数据库名`

由于有了ORM,我们向数据库表中添加一行记录,可以视为添加一个User对象:

# 创建所有定义的表到数据库中
Base.metadata.create_all(engine)
# 创建session对象:
session = DBSession()
# 创建新User对象:
user1 = User(id='1', name='wasd')
user2 = User(id='2', name='zxc')
user3 = User(id='3', name='qwe')
user4 = User(id='4', name='rty')
user5 = User(id='5', name='vbn')
user6 = User(id='6', name='fgh')
# 添加到session:
session.add(user1)
session.add(user2)
session.add(user3)
session.add(user4)
session.add(user5)
session.add(user6)
# 提交即保存到数据库:
session.commit()
# 关闭session:
session.close()
# 关键是获取session,然后把对象添加到session,最后提交并关闭。DBSession对象可视为当前数据库连接。

查询数据

# 查询数据
# 创建Session:
session = DBSession()
# 创建Query查询,filter是where条件,最后调用one()返回唯一行,如果调用all()则返回所有行:
user = session.query(User).filter(User.id=='1').one()
users = session.query(User).filter(User.id!='1').all()
# 打印类型和对象的name属性:
print('type:', type(user))
print('name:', user.name)
for user in users:
print('type:', type(user))
print('name:', user.name)
# 关闭Session:
session.close()

运行结果:

type: <class '__main__.User'>
name: wasd
type: <class '__main__.User'>
name: zxc
type: <class '__main__.User'>
name: qwe
type: <class '__main__.User'>
name: rty
type: <class '__main__.User'>
name: vbn
type: <class '__main__.User'>
name: fgh

ORM就是把数据库表的行与相应的对象建立关联,互相转换。

由于关系数据库的多个表还可以用外键实现一对多、多对多等关联,相应地,ORM框架也可以提供两个对象之间的一对多、多对多等功能。

例如,如果一个User拥有多个Book,就可以定义一对多关系如下:

class User(Base):
      __tablename__ = 'user'
      __table_args__ = {'extend_existing': True}
      id = Column(String(20), primary_key=True)
      name = Column(String(20))
      # 一对多:
      books = relationship('Book')
class Book(Base):
      __tablename__ = 'book'
      id = Column(String(20), primary_key=True)
      name = Column(String(20))
      # “多”的一方的book表是通过外键关联到user表的:
      user_id = Column(String(20), ForeignKey('user.id'))
# 当我们查询一个User对象时,该对象的books属性将返回一个包含若干个Book对象的list。
# 创建所有定义的表到数据库中
Base.metadata.create_all(engine)

更多用法可参考:这篇文章 https://www.jianshu.com/p/65903a69d61d



Tags:Python 连接数据库   点击:()  评论:()
声明:本站部分内容及图片来自互联网,转载是出于传递更多信息之目的,内容观点仅代表作者本人,如有任何标注错误或版权侵犯请与我们联系(Email:2595517585@qq.com),我们将及时更正、删除,谢谢。
▌相关推荐
连接SQLite要操作关系数据库,首先需要连接到数据库,一个数据库连接称为Connection;连接到数据库后,需要打开游标,称之为Cursor,通过Cursor执行SQL语句,然后,获得执行结果。Python定...【详细内容】
2020-06-19  Tags: Python 连接数据库  点击:(32)  评论:(0)  加入收藏
▌简易百科推荐
大家好,我是菜鸟哥,今天跟大家一起聊一下Python4的话题! 从2020年的1月1号开始,Python官方正式的停止了对于Python2的维护。Python也正式的进入了Python3的时代。而随着时间的...【详细内容】
2021-12-28  菜鸟学python    Tags:Python4   点击:(1)  评论:(0)  加入收藏
学习Python的初衷是因为它的实践的便捷性,几乎计算机上能完成的各种操作都能在Python上找到解决途径。平时工作需要在线学习。而在线学习的复杂性经常让人抓狂。费时费力且效...【详细内容】
2021-12-28  风度翩翩的Python    Tags:Python   点击:(1)  评论:(0)  加入收藏
Python 是一个很棒的语言。它是世界上发展最快的编程语言之一。它一次又一次地证明了在开发人员职位中和跨行业的数据科学职位中的实用性。整个 Python 及其库的生态系统使...【详细内容】
2021-12-27  IT资料库    Tags:Python 库   点击:(2)  评论:(0)  加入收藏
菜单驱动程序简介菜单驱动程序是通过显示选项列表从用户那里获取输入并允许用户从选项列表中选择输入的程序。菜单驱动程序的一个简单示例是 ATM(自动取款机)。在交易的情况下...【详细内容】
2021-12-27  子冉爱python    Tags:Python   点击:(4)  评论:(0)  加入收藏
有不少同学学完Python后仍然很难将其灵活运用。我整理15个Python入门的小程序。在实践中应用Python会有事半功倍的效果。01 实现二元二次函数实现数学里的二元二次函数:f(x,...【详细内容】
2021-12-22  程序汪小成    Tags:Python入门   点击:(32)  评论:(0)  加入收藏
Verilog是由一个个module组成的,下面是其中一个module在网表中的样子,我只需要提取module名字、实例化关系。module rst_filter ( ...); 端口声明... wire定义......【详细内容】
2021-12-22  编程啊青    Tags:Verilog   点击:(8)  评论:(0)  加入收藏
运行环境 如何从 MP4 视频中提取帧 将帧变成 GIF 创建 MP4 到 GIF GUI ...【详细内容】
2021-12-22  修道猿    Tags:Python   点击:(6)  评论:(0)  加入收藏
面向对象:Object Oriented Programming,简称OOP,即面向对象程序设计。类(Class)和对象(Object)类是用来描述具有相同属性和方法对象的集合。对象是类的具体实例。比如,学生都有...【详细内容】
2021-12-22  我头秃了    Tags:python   点击:(9)  评论:(0)  加入收藏
所谓内置函数,就是Python提供的, 可以直接拿来直接用的函数,比如大家熟悉的print,range、input等,也有不是很熟,但是很重要的,如enumerate、zip、join等,Python内置的这些函数非常...【详细内容】
2021-12-21  程序员小新ds    Tags:python初   点击:(5)  评论:(0)  加入收藏
Hi,大家好。我们在接口自动化测试项目中,有时候需要一些加密。今天给大伙介绍Python实现各种 加密 ,接口加解密再也不愁。目录一、项目加解密需求分析六、Python加密库PyCrypto...【详细内容】
2021-12-21  Python可乐    Tags:Python   点击:(8)  评论:(0)  加入收藏
最新更新
栏目热门
栏目头条