数据库状态检测
(self, get)
| 1203 | return password |
| 1204 | |
| 1205 | def CheckDatabaseStatus(self, get): |
| 1206 | """ |
| 1207 | 数据库状态检测 |
| 1208 | """ |
| 1209 | if not hasattr(get, "sid"): |
| 1210 | return public.returnMsg(False, "缺少参数！sid") |
| 1211 | if not str(get.sid).isdigit(): |
| 1212 | return public.returnMsg(False, "参数错误！sid") |
| 1213 | sid = int(get.sid) |
| 1214 | |
| 1215 | pgsql_obj = panelPgsql() |
| 1216 | if sid == 0: |
| 1217 | db_status, err_msg = pgsql_obj.connect() |
| 1218 | else: |
| 1219 | conn_config = public.M("database_servers").where("id=? AND LOWER(db_type)=LOWER('pgsql')", (sid,)).find() |
| 1220 | if not conn_config: |
| 1221 | db_status = False |
| 1222 | err_msg = "远程数据库信息不存在！" |
| 1223 | else: |
| 1224 | pgsql_obj.set_host(host=conn_config["db_host"], port=conn_config["db_port"], database=None, user=conn_config["db_user"], password=conn_config["db_password"]) |
| 1225 | db_status, err_msg = pgsql_obj.connect() |
| 1226 | |
| 1227 | return {"status": True if db_status is True else False, "msg": "正常" if db_status is True else "异常", "db_status": db_status, "err_msg": err_msg} |
| 1228 | |
| 1229 | def check_cloud_database_status(self, conn_config): |
| 1230 | """ |