python使用数据库

本文涉及的产品
RDS MySQL DuckDB 分析主实例,集群系列 4核8GB
简介:

使用python-DB-API,只需要搞清楚Connection、Cursor对象,打开后一定得关闭。


Cursor对象执行insert、update、delete,结果由rowcount返回影响的行数,拿到执行结果。


Cursor对象执行select,通过featchall()拿到list的结果集,每个元素都是一个tuple,对应一行记录


SQL带有参数,需要把参数按照位置传递给execute()方法。


安装mysql官方提供的python驱动

pip install mysql-connection-python --allow-external mysql-connection-python


操作mysql的步骤:

import mysql.connector

conn=mysql.connector.connect(user='root', password='password', database='test')

cursor=conn.cursor()

cursor.execute('create table user(id varchar(20) primary key, name varchar(20))')

cursor.execute('insert into user(id, name) values(%s, %s)', ['1', 'Michael'])

cursor.rowcount


conn.commit()

cursor.close()


cursor = conn.cursor()

cursor.execute('select * from user where id = %s', ['1'])

values = cursor.fetchall()

values


cursor.close()

conn.close()


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

ORM框架 -- SQLAlchemy 

SQLAlchemy的应用, 初始化DBSession

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
from  sqlalchemy  import  Column, String, create_engine
from  sqlalchemy.orm  import  sessionmaker
from  sqlalchemy.ext.declarative  import  declarative_base
 
Base  =  declarative_base()
 
class  User(Base):
     __tablename__  =  'user'
     
     id  =  Column(String( 20 ), primary_key  =  True )
     name  =  Column(String( 20 ))
     
     
engine  =  create_engine( 'mysql+mysqlconnector://root:password@localhost:3306/test' )
 
DBSession  =  sessionmaker(bind = engine)

一个表对应一个class。使用ORM添加记录,可以看成为添加一个User对象。

1
2
3
4
5
6
session  =  DBSession()
new_user = User( id = '5' , name = 'bob' )
 
session.add(new_user)
session.commit()
session.close()

添加数据的关键是获取session,然后把对象添加到session,最后提交并关闭。DBSession对象可视为当前数据库连接。

使用ORM从数据库中查询数据:结果是一个user对象,而不是tuple。

1
2
3
4
5
6
7
session  =  DBSession()
 
user  =  session.query(User). filter (User. id = = '5' ).one()
 
print ( 'type:' type (user)
print ( 'name:' , user.name)
session.close()

多个表通过外键实现一对多,多对多的关联。ORM框架也可以实现一对多,多对多功能。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
class  User(Base):
     __tablename__  =  'user'
     
     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 ))
     
     user_id  =  Column(String( 20 ), ForeignKey( 'user,id' ))

查询一个User对象时,该对象的books属性将返回一个包含若干个Book对象的list。


ORM的作用就是把数据库表的一行记录与一个对象做相互转换, 使用ORM的前提是了解关系数据库的原理。













本文转自ting2junshui51CTO博客,原文链接: http://blog.51cto.com/ting2junshui/1753482,如需转载请自行联系原作者



相关实践学习
每个IT人都想学的“Web应用上云经典架构”实战
本实验从Web应用上云这个最基本的、最普遍的需求出发,帮助IT从业者们通过“阿里云Web应用上云解决方案”,了解一个企业级Web应用上云的常见架构,了解如何构建一个高可用、可扩展的企业级应用架构。
MySQL数据库入门学习
本课程通过最流行的开源数据库MySQL带你了解数据库的世界。   相关的阿里云产品:云数据库RDS MySQL 版 阿里云关系型数据库RDS(Relational Database Service)是一种稳定可靠、可弹性伸缩的在线数据库服务,提供容灾、备份、恢复、迁移等方面的全套解决方案,彻底解决数据库运维的烦恼。 了解产品详情: https://www.aliyun.com/product/rds/mysql 
相关文章
|
2月前
|
SQL 关系型数据库 数据库
Python SQLAlchemy模块:从入门到实战的数据库操作指南
免费提供Python+PyCharm编程环境,结合SQLAlchemy ORM框架详解数据库开发。涵盖连接配置、模型定义、CRUD操作、事务控制及Alembic迁移工具,以电商订单系统为例,深入讲解高并发场景下的性能优化与最佳实践,助你高效构建数据驱动应用。
401 7
|
3月前
|
数据采集 关系型数据库 MySQL
python爬取数据存入数据库
Python爬虫结合Scrapy与SQLAlchemy,实现高效数据采集并存入MySQL/PostgreSQL/SQLite。通过ORM映射、连接池优化与批量提交,支持百万级数据高速写入,具备良好的可扩展性与稳定性。
|
3月前
|
存储 数据库 开发者
Python SQLite模块:轻量级数据库的实战指南
本文深入讲解Python内置sqlite3模块的实战应用,涵盖数据库连接、CRUD操作、事务管理、性能优化及高级特性,结合完整案例,助你快速掌握SQLite在小型项目中的高效使用,是Python开发者必备的轻量级数据库指南。
355 0
|
7月前
|
SQL 数据库 开发者
Python中使用Flask-SQLAlchemy对数据库的增删改查简明示例
这样我们就对Flask-SQLAlchemy进行了一次简明扼要的旅程,阐述了如何定义模型,如何创建表,以及如何进行基本的数据库操作。希望你在阅读后能对Flask-SQLAlchemy有更深入的理解,这将为你在Python世界中从事数据库相关工作提供极大的便利。
712 77
|
9月前
|
数据库 Python
【YashanDB知识库】python驱动查询gbk字符集崖山数据库CLOB字段,数据被驱动截断
【YashanDB知识库】python驱动查询gbk字符集崖山数据库CLOB字段,数据被驱动截断
|
10月前
|
关系型数据库 数据库 数据安全/隐私保护
云数据库实战:基于阿里云RDS的Python应用开发与优化
在互联网时代,数据驱动的应用已成为企业竞争力的核心。阿里云RDS为开发者提供稳定高效的数据库托管服务,支持多种数据库引擎,具备自动化管理、高可用性和弹性扩展等优势。本文通过Python应用案例,从零开始搭建基于阿里云RDS的数据库应用,详细演示连接、CRUD操作及性能优化与安全管理实践,帮助读者快速上手并提升应用性能。
|
关系型数据库 MySQL 数据库连接
python脚本:连接数据库,检查直播流是否可用
【10月更文挑战第13天】本脚本使用 `mysql-connector-python` 连接MySQL数据库,检查 `live_streams` 表中每个直播流URL的可用性。通过 `requests` 库发送HTTP请求,输出每个URL的检查结果。需安装 `mysql-connector-python` 和 `requests` 库,并配置数据库连接参数。
284 68
|
9月前
|
SQL 关系型数据库 数据库连接
|
关系型数据库 MySQL 数据库
Python处理数据库:MySQL与SQLite详解 | python小知识
本文详细介绍了如何使用Python操作MySQL和SQLite数据库,包括安装必要的库、连接数据库、执行增删改查等基本操作,适合初学者快速上手。
1161 15
|
关系型数据库 MySQL 数据处理
探索Python中的异步编程:从asyncio到异步数据库操作
在这个快节奏的技术世界里,效率和性能是关键。本文将带你深入Python的异步编程世界,从基础的asyncio库开始,逐步探索到异步数据库操作的高级应用。我们将一起揭开异步编程的神秘面纱,探索它如何帮助我们提升应用程序的性能和响应速度。

推荐镜像

更多