浏览代码

feat: 支持自定义Database名称

SongZihuan 2 年之前
父节点
当前提交
2b6a373174
共有 3 个文件被更改,包括 13 次插入4 次删除
  1. 2 1
      configure/__init__.py
  2. 5 1
      sql/__init__.py
  3. 6 2
      sql/mysql.py

+ 2 - 1
configure/__init__.py

@@ -11,9 +11,10 @@ conf = {
     "INTRODUCTION": "",
     "INTRODUCTION_LINK": "",
     "MYSQL_URL": "localhost",
-    "MYSQL_NAME": "local",
+    "MYSQL_NAME": "localhost",
     "MYSQL_PASSWD": "123456",
     "MYSQL_PORT": 3306,
+    "MYSQL_DATABASE": "HBlog",
     "MAIL_SERVER": "",
     "MAIL_PORT": "",
     "MAIL_USE_TLS": False,

+ 5 - 1
sql/__init__.py

@@ -3,4 +3,8 @@ from configure import conf
 
 
 DB = MysqlDB
-db = DB(host=conf["MYSQL_URL"], name=conf["MYSQL_NAME"], passwd=conf["MYSQL_PASSWD"], port=conf["MYSQL_PORT"])
+db = DB(host=conf["MYSQL_URL"],
+        name=conf["MYSQL_NAME"],
+        passwd=conf["MYSQL_PASSWD"],
+        port=conf["MYSQL_PORT"],
+        database=conf["MYSQL_DATABASE"])

+ 6 - 2
sql/mysql.py

@@ -15,16 +15,20 @@ class MysqlDB(Database):
                  host: Optional[str],
                  name: Optional[str],
                  passwd: Optional[str],
-                 port: Optional[str]):
+                 port: Optional[str],
+                 database: str = "HBlog"):
         if host is None or name is None:
             raise DBException
+
         super(MysqlDB, self).__init__(host=host, name=name, passwd=passwd, port=port)
+        self.database = database
+
         try:
             self._db = pymysql.connect(user=self._name,
                                        password=self._passwd,
                                        host=self._host,
                                        port=self._port,
-                                       database="HBlog")
+                                       database=self.database)
         except pymysql.err.OperationalError:
             raise
         self._cursor = self._db.cursor()