我正在为一个 Python 项目使用 SQLalchemy,我希望有一个整洁的连接字符串来访问我的数据库。例如:
engine = create_engine('postgresql://user:pass@host/database')
问题是我的密码包含一系列特殊字符,当我尝试连接时,这些字符被解释为分隔符。
我意识到我可以只使用
engine.URL.create()
然后像这样传递我的凭据:
import sqlalchemy as sa
connection_url = sa.engine.URL.create(
drivername="postgresql",
username="user",
password="p@ss",
host="host",
database="database",
)
print(connection_url)
# postgresql://user:p%40ss@host/database
但如果可能的话,我更愿意使用连接字符串。
所以要清楚,是否可以对我的连接字符串或连接字符串的密码部分进行编码 - 以便可以正确解析它?
您需要对连接字符串的密码部分进行 URL 编码:
from urllib.parse import quote_plus
from sqlalchemy.engine import create_engine
engine = create_engine("postgres://user:%s@host/database" % quote_plus("p@ss"))
如果您查看 SQLAlchemy 中用于表示数据库连接 URL 的类的实现(在
sqlalchemy/engine/url.py
中),您会发现它们在将 URL 实例转换为字符串时使用相同的方法来转义密码。
在 Python 3.x 中,需要导入 urllib.parse.quote:
urllib 模块已拆分为多个部分,并在 Python 3 中重命名为 urllib.request、urllib.parse 和 urllib.error.
当您尝试使用包含特殊字符序列的密码连接数据库 MySQL 并且您的 python 版本是 Python3
user_name 是您的数据库用户名
database 是你的数据库名称
your_password 带特殊字符的密码
from urllib.parse import quote
from sqlalchemy.engine import create_engine
engine = create_engine('mysql+mysqlconnector://user_name:%s@localhost:3306/database' % quote('your_password'))
密码中包含"@",您可以使用"%40"转义"@"字符。
之前:
mssql+pymssql://admin:[email protected]/dbtest
之后:
mssql+pymssql://admin:admin%[email protected]/dbtest
使用 urllib.parse.quote_plus.
对密码进行编码DATABASE_PASSWORD = "admin@123"
# to elimate the error, if the password contains special characters like '@'
DATABASE_PASSWORD_UPDATED = urllib.parse.quote_plus(DATABASE_PASSWORD)
这是完整的代码片段:
import os, sys, click, urllib
from flask import Flask, jsonify, request
from flask_sqlalchemy import SQLAlchemy
from sqlalchemy import text
# Make sure to replace below data with your DB values
DATABASE_HOST = "10.10.10.110"
DATABASE_NAME = "dbtest"
DATABASE_USERNAME = "admin"
DATABASE_PASSWORD = "admin@123"
app = Flask(__name__)
# to elimate the error, if the password contains special characters like '@'
# replace the DATABASE_PASSWORD with DATABASE_PASSWORD_UPDATED.
DATABASE_PASSWORD_UPDATED = urllib.parse.quote_plus(DATABASE_PASSWORD)
app.config['SQLALCHEMY_DATABASE_URI'] = 'mssql+pymssql://'+DATABASE_USERNAME+':'+DATABASE_PASSWORD_UPDATED+'@'+DATABASE_HOST+'/'+DATABASE_NAME
app.config['SQLALCHEMY_ECHO'] = True
db = SQLAlchemy(app)
if __name__ == "__main__":
app.run(host="0.0.0.0", port=5000, debug=True)