Python对接六大主流数据库，只需三步("Python快速对接六大主流数据库攻略：仅需三步搞定")

原创

ithorizon 7个月前 (10-21) 阅读数 29 #后端开发

Python迅速对接六大主流数据库攻略：仅需三步搞定

一、引言

在软件开发过程中，数据库操作是不可或缺的一部分。Python作为一种强势的编程语言，拥有多彩的数据库接口和库，可以轻松对接六大主流数据库：MySQL、PostgreSQL、SQLite、Oracle、SQL Server 和 MongoDB。本文将为您详细介绍怎样通过三步实现Python与这些主流数据库的对接。

二、准备工作

在进行数据库对接之前，您需要确保以下准备工作已完成：

安装Python环境

安装数据库驱动库

确保数据库已安装并运行

三、Python对接六大主流数据库的三步攻略

1. MySQL数据库对接

MySQL是最流行的关系型数据库之一，Python可以使用MySQLdb或pymysql库进行对接。

第一步：安装MySQL驱动库

pip install pymysql

第二步：连接数据库


import pymysql
# 数据库配置信息
config = {
    'host': 'localhost',
    'port': 3306,
    'user': 'root',
    'password': 'password',
    'database': 'testdb',
    'charset': 'utf8'
}
# 连接数据库
connection = pymysql.connect(**config)
cursor = connection.cursor()

第三步：执行SQL语句


# 创建表
create_table_sql = """
CREATE TABLE IF NOT EXISTS users (
    id INT AUTO_INCREMENT PRIMARY KEY,
    name VARCHAR(100) NOT NULL,
    age INT NOT NULL
)
"""
cursor.execute(create_table_sql)
# 插入数据
insert_sql = "INSERT INTO users (name, age) VALUES (%s, %s)"
cursor.execute(insert_sql, ('Alice', 25))
# 查询数据
select_sql = "SELECT * FROM users"
cursor.execute(select_sql)
results = cursor.fetchall()
for row in results:
    print(row)
# 关闭连接
cursor.close()
connection.close()

2. PostgreSQL数据库对接

PostgreSQL是一个功能强势的开源对象-关系型数据库系统，Python可以使用psycopg2库进行对接。

第一步：安装PostgreSQL驱动库

pip install psycopg2

第二步：连接数据库


import psycopg2
# 数据库配置信息
config = {
    'host': 'localhost',
    'port': 5432,
    'user': 'postgres',
    'password': 'password',
    'database': 'testdb'
}
# 连接数据库
connection = psycopg2.connect(**config)
cursor = connection.cursor()

第三步：执行SQL语句


# 创建表
create_table_sql = """
CREATE TABLE IF NOT EXISTS users (
    id SERIAL PRIMARY KEY,
    name VARCHAR(100) NOT NULL,
    age INT NOT NULL
)
"""
cursor.execute(create_table_sql)
# 插入数据
insert_sql = "INSERT INTO users (name, age) VALUES (%s, %s)"
cursor.execute(insert_sql, ('Bob', 30))
# 查询数据
select_sql = "SELECT * FROM users"
cursor.execute(select_sql)
results = cursor.fetchall()
for row in results:
    print(row)
# 关闭连接
cursor.close()
connection.close()

3. SQLite数据库对接

SQLite是一个轻量级的数据库，Python内置了sqlite3模块，可以直接进行对接。

第一步：无需安装驱动库

第二步：连接数据库


import sqlite3
# 数据库文件路径
db_path = 'test.db'
# 连接数据库
connection = sqlite3.connect(db_path)
cursor = connection.cursor()

第三步：执行SQL语句


# 创建表
create_table_sql = """
CREATE TABLE IF NOT EXISTS users (
    id INTEGER PRIMARY KEY AUTOINCREMENT,
    name TEXT NOT NULL,
    age INTEGER NOT NULL
)
"""
cursor.execute(create_table_sql)
# 插入数据
insert_sql = "INSERT INTO users (name, age) VALUES (?, ?)"
cursor.execute(insert_sql, ('Charlie', 35))
# 查询数据
select_sql = "SELECT * FROM users"
cursor.execute(select_sql)
results = cursor.fetchall()
for row in results:
    print(row)
# 关闭连接
cursor.close()
connection.close()

4. Oracle数据库对接

Oracle是一个强势的商业数据库系统，Python可以使用cx_Oracle库进行对接。

第一步：安装Oracle驱动库

pip install cx_Oracle

第二步：连接数据库


import cx_Oracle
# 数据库配置信息
config = {
    'user': 'oracle_user',
    'password': 'oracle_password',
    'dsn': 'localhost/orclpdb1'
}
# 连接数据库
connection = cx_Oracle.connect(**config)
cursor = connection.cursor()

第三步：执行SQL语句


# 创建表
create_table_sql = """
CREATE TABLE IF NOT EXISTS users (
    id NUMBER PRIMARY KEY,
    name VARCHAR2(100) NOT NULL,
    age NUMBER NOT NULL
)
"""
cursor.execute(create_table_sql)
# 插入数据
insert_sql = "INSERT INTO users (id, name, age) VALUES (:id, :name, :age)"
cursor.execute(insert_sql, {'id': 1, 'name': 'David', 'age': 40})
# 查询数据
select_sql = "SELECT * FROM users"
cursor.execute(select_sql)
results = cursor.fetchall()
for row in results:
    print(row)
# 关闭连接
cursor.close()
connection.close()

5. SQL Server数据库对接

SQL Server是微软开发的关系型数据库系统，Python可以使用pyodbc或pymssql库进行对接。

第一步：安装SQL Server驱动库

pip install pyodbc

第二步：连接数据库


import pyodbc
# 数据库配置信息
conn_str = (
    'DRIVER={SQL Server};'
    'SERVER=localhost;'
    'DATABASE=testdb;'
    'UID=sa;'
    'PWD=password;'
)
# 连接数据库
connection = pyodbc.connect(conn_str)
cursor = connection.cursor()

第三步：执行SQL语句


# 创建表
create_table_sql = """
CREATE TABLE IF NOT EXISTS users (
    id INT PRIMARY KEY,
    name NVARCHAR(100) NOT NULL,
    age INT NOT NULL
)
"""
cursor.execute(create_table_sql)
# 插入数据
insert_sql = "INSERT INTO users (id, name, age) VALUES (?, ?, ?)"
cursor.execute(insert_sql, (1, 'Eve', 45))
# 查询数据
select_sql = "SELECT * FROM users"
cursor.execute(select_sql)
results = cursor.fetchall()
for row in results:
    print(row)
# 关闭连接
cursor.close()
connection.close()

6. MongoDB数据库对接

MongoDB是一个流行的NoSQL数据库，Python可以使用pymongo库进行对接。

第一步：安装MongoDB驱动库

pip install pymongo

第二步：连接数据库


from pymongo import MongoClient
# 数据库配置信息
client = MongoClient('localhost', 27017)
db = client['testdb']
collection = db['users']

第三步：执行数据库操作


# 插入数据
user_data = {'name': 'Frank', 'age': 50}
collection.insert_one(user_data)
# 查询数据
results = collection.find()
for row in results:
    print(row)
# 关闭连接
client.close()