本文将以 MySQL 为例,讲解如何连接远程数据库并进行相关的数据库操作。
可能是最方便连接的数据库,因为我们不需要安装任何外部 SQL 模块即可使用。默认情况下,它带有一个名为 SQL 的 SQL 库,我们可以使用它与数据库进行交互。而且,我们甚至不需要安装和运行服务器来执行数据库操作!
下面是连接数据库的方法,看代码,关键位置注释了
#导入相关模块
import sqlite3
from sqlite3 import Error
def create_connection(path):
connection = None
try:
#使用.connect()连接,并将SQLite数据库路径作为参数。如果数据库位于指定位置,则建立与数据库的连接。否则,将在指定位置创建一个新数据库,并建立连接。
connection = sqlite3.connect(path)
print("成功连接")
except Error as e:
print(f"错误 '{e}' 发生")
return connection
(path) 返回一个连接对象,由() 返回。此连接对象可用于对数据库执行查询。然后执行以下命令连接数据库
connection = create_connection("填写你的路径filename.sqlite")
执行后,您会看到一个以 .在目录中。
不同的是,没有可用于连接 MySQL 数据库的默认 SQL 模块。相反,我们需要安装 mysql — 以便在应用程序中与 MySQL 数据库进行交互。
pip mysql–
然而问道私服连接到数据库怎么修改,应该注意的是,MySQL 是一个基于服务器的数据库管理系统。一个 MySQL 服务器可以有多个数据库。不同的是问道私服连接到数据库怎么修改,创建连接相当于在 MySQL 中创建数据库,创建数据库有两个步骤:首先建立与 MySQL 服务器的连接,然后执行单独的查询来创建数据库。
import mysql.connector
from mysql.connector import Error
def create_connection(host_name, user_name, user_password):
connection = None
try:
#创建连接
connection = mysql.connector.connect(
host=host_name,
user=user_name,
passwd=user_password
)
print("连接成功")
except Error as e:
print(f"错误 '{e}' 发生")
return connection
connection = create_connection("localhost", "root", "")
但是到目前为止,我们只成功连接了mysql,没有创建,所以我们定义了另一个()函数,它接受两个参数:要与之交互的数据库服务器的对象。 query 是创建数据库的查询。
def create_database(connection, query):
cursor = connection.cursor()
try:
cursor.execute(query)
print("Database created successfully")
except Error as e:
print(f"The error '{e}' occurred")
要执行查询,我们可以使用对象。将要执行的查询传递给.()
create_database_query = "CREATE DATABASE zaoqi" #创建database
create_database(connection, create_database_query)
至此,我们已经在数据库服务器上创建了一个数据库。
与 MySQL 一样,没有用于与数据库交互的默认 SQL 库。因此,需要安装第三方 SQL 驱动程序才能与之交互。想知道我们选择的驱动因素是什么。
点
与MySQL数据库一样,我们定义()与数据库建立连接:
import psycopg2
from psycopg2 import OperationalError
def create_connection(db_name, db_user, db_password, db_host, db_port):
connection = None
try:
connection = psycopg2.connect(
database=db_name,
user=db_user,
password=db_password,
host=db_host,
port=db_port,
)
print("Connection to PostgreSQL DB successful")
except OperationalError as e:
print(f"The error '{e}' occurred")
return connection
然后用和mysql一样的方法创建一个
def create_database(connection, query):
connection.autocommit = True
cursor = connection.cursor()
try:
cursor.execute(query)
print("Query executed successfully")
except OperationalError as e:
print(f"The error '{e}' occurred")
create_database_query = "CREATE DATABASE zaoqi"
create_database(connection, create_database_query)
至此我们已经学会了如何连接数据库和创建,其他操作如增删改查可以类推。
最新评论