设置连接参数
(self, *args, **kwargs)
| 87 | |
| 88 | # 设置连接参数 |
| 89 | def set_host(self, *args, **kwargs): |
| 90 | """ |
| 91 | 设置连接参数 |
| 92 | """ |
| 93 | # args 兼容老版本，后续新增禁止使用 args |
| 94 | if len(args) >= 5: |
| 95 | kwargs["host"] = args[0] |
| 96 | kwargs["port"] = args[1] |
| 97 | kwargs["database"] = args[2] |
| 98 | kwargs["user"] = args[3] |
| 99 | kwargs["password"] = args[4] |
| 100 | |
| 101 | if kwargs.get("db_host") is not None: |
| 102 | kwargs["host"] = kwargs.get("db_host") |
| 103 | if kwargs.get("db_port") is not None: |
| 104 | kwargs["port"] = kwargs.get("db_port") |
| 105 | if kwargs.get("db_name") is not None: |
| 106 | kwargs["database"] = kwargs.get("db_name") |
| 107 | if kwargs.get("db_user") is not None: |
| 108 | kwargs["user"] = kwargs.get("db_user") |
| 109 | if kwargs.get("db_password") is not None: |
| 110 | kwargs["password"] = kwargs.get("db_password") |
| 111 | self.__CONN_KWARGS.update(kwargs) |
| 112 | |
| 113 | if not isinstance(self.__CONN_KWARGS["port"], int): |
| 114 | self.__CONN_KWARGS["port"] = int(self.__CONN_KWARGS["port"]) |
| 115 | return self |
| 116 | |
| 117 | def execute(self, sql): |
| 118 | # 执行SQL语句返回受影响行 |
no test coverage detected