@取pgsql数据库对象 @db_name 数据库名称
(self, db_name)
| 311 | return db_obj |
| 312 | |
| 313 | def get_sql_obj(self, db_name): |
| 314 | """ |
| 315 | @取pgsql数据库对象 |
| 316 | @db_name 数据库名称 |
| 317 | """ |
| 318 | is_cloud_db = False |
| 319 | if db_name: |
| 320 | db_find = public.M('databases').where("name=? AND LOWER(type)=LOWER('PgSql')", db_name).find() |
| 321 | if db_find['sid']: |
| 322 | return self.get_sql_obj_by_sid(db_find['sid']) |
| 323 | is_cloud_db = db_find['db_type'] in ['1', 1] |
| 324 | |
| 325 | if is_cloud_db: |
| 326 | |
| 327 | db_obj = panelPgsql() |
| 328 | conn_config = json.loads(db_find['conn_config']) |
| 329 | try: |
| 330 | db_obj = db_obj.set_host(host=conn_config["db_host"], port=conn_config["db_port"], database=conn_config["db_name"], user=conn_config["db_user"], password=conn_config["db_password"]) |
| 331 | except Exception as e: |
| 332 | raise public.PanelError(e) |
| 333 | else: |
| 334 | db_obj = panelPgsql() |
| 335 | return db_obj |
| 336 | |
| 337 | def GetCloudServer(self, args): |
| 338 | ''' |
no test coverage detected