Python 实现程序与数据库的无缝连结 (python将程序写入数据库)
Python 是一种功能强大的编程语言,它已成为许多开发者的首选语言。当需要访问数据库时,Python 也有许多基于不同数据库的库,如 MySQL、PostgreSQL、SQLite。在实践过程中,有许多方法,下面将介绍其中的两种方法。
一、使用 PyMySQL 库连接 MySQL 数据库
1.1 安装
在 Linux 和 Mac 上,可以在终端中使用以下命令安装 PyMySQL。
“`
pip install PyMySQL
“`
在 Windows 上,也可以使用以上命令安装,或下载 PyMySQL 的 Windows 版本。
1.2 使用
要使用 PyMySQL 连接 MySQL 数据库,需要用户名、密码、主机和数据库名称。可以在 Python 中这样写。
“`Python
import pymysql
connection = pymysql.connect(host=’localhost’, user=’root’,
password=’password’, db=’database_name’)
“`
可以使用之前设定的连接来创建和执行 MySQL 语句。
“`Python
try:
with connection.cursor() as cursor:
# Create a new record
sql = “INSERT INTO `users` (`eml`, `password`) VALUES (%s, %s)”
cursor.execute(sql, (‘example@domn.com’, ‘123456’))
# connection is not autocommit by default. So you must commit to save
# your changes.
connection.commit()
with connection.cursor() as cursor:
# Read a single record
sql = “SELECT `id`, `password` FROM `users` WHERE `eml`=%s”
cursor.execute(sql, (‘example@domn.com’,))
result = cursor.fetchone()
print(result)
finally:
connection.close()
“`
以上代码将创建一个名为 ‘users’ 的表并插入一条记录。然后从 ‘users’ 表中选择 eml=example@domn.com 对应的记录并打印出来。
除了 PyMySQL 库,还有其他库也可以用于访问 MySQL 数据库,比如 mysql-connector-python 和 PyMySQLdb。
二、使用 SQLAlchemy 库连接 MySQL 数据库
2.1 安装
还是使用 pip 命令可以在 Python 中安装 SQLAlchemy。
“`
pip install SQLAlchemy
“`
2.2 使用
SQLAlchemy 库提供了 ORM 和 SQL 语句两种方式来操作数据库。ORM 会将数据映射到 Python 中的类并提供了一个操作这些类的 API。使用 SQL 语句时,需要编写 SQL 语句并执行。
ORM 方式:
当使用 ORM 方式时,首先需要创建一个引擎。
“`Python
from sqlalchemy import create_engine
engine = create_engine(‘mysql+pymysql://root:password@localhost/database_name’)
“`
然后定义一个用户表。
“`Python
from sqlalchemy import Table, Column, Integer, String, MetaData
metadata = MetaData()
users = Table(‘users’, metadata,
Column(‘id’, Integer, primary_key=True),
Column(‘username’, String(32)),
Column(‘password’, String(32)),
Column(’eml’, String(64))
)
“`
接下来可以使用 SQLalchemy ORM 提供的 API 来操作数据库。
“`Python
from sqlalchemy import insert, select
insert_stmt = users.insert().values(username=’user’, password=’password’, eml=’user@example.com’)
engine.execute(insert_stmt)
select_stmt = select([users]).where(users.c.username == ‘user’)
result = engine.execute(select_stmt).fetchall()
print(result)
“`
以上代码将会创建一个名为 ‘users’ 的表并插入一条记录。之后从 ‘users’ 表中选择 username=user 对应的记录并打印出来。
SQL 语句方式:
当使用 SQL 语句方式时,可以使用 SQLAlchemy 的 session 连接数据库。
“`Python
from sqlalchemy.orm import sessionmaker
Session = sessionmaker(bind=engine)
session = Session()
“`
然后就可以使用 SQL 语句来操作数据库。
“`Python
from sqlalchemy.sql import text
insert_stmt = text(“INSERT INTO users (username, password, eml) VALUES (:username, :password, :eml)”)
engine.execute(insert_stmt, username=’user’, password=’password’, eml=’user@example.com’)
select_stmt = text(“SELECT * FROM users WHERE username=:username”)
result = engine.execute(select_stmt, username=’user’).fetchall()
print(result)
“`
以上代码将会创建一个名为 ‘users’ 的表并插入一条记录。之后从 ‘users’ 表中选择 username=user 对应的记录并打印出来。
本文介绍了两种使用 Python 实现程序与数据库无缝连接的方法。之一种是使用 PyMySQL 库连接 MySQL 数据库,并执行 SQL 语句。第二种是使用 SQLAlchemy 库连接 MySQL 数据库,并使用 ORM 或 SQL 语句操作数据库。实验验证了这两种方法都可以实现对数据库的访问和操作。开发者可以通过 Python 中不同库的选项,按需为项目选择最适合的库来进行开发。