Method query_sql_by_id

solidui/views/metadata/api.py:192–227

(self)

    @expose('/querySql/id', methods=("GET",))
    @safe
    def query_sql_by_id(self) -> FlaskResponse:
        data_source_id = request.args.get('dataSourceId', type=int)
        sql = request.args.get('sql')
        # Call the service method to execute the SQL query by ID. You need to implement this logic

        # Call the service method to get table data. You need to implement this logic
        data_source = DataSourceDAO.get_data_source_id(data_source_id)
        if data_source is None:
            return self.handle_error(SolidUIErrorType.QUERY_DATASOURCE_ERROR)

        data_source_type = DataSourceTypeDAO.get_id(data_source.datasource_type_id)
        if data_source_type is None:
            return self.handle_error(SolidUIErrorType.QUERY_DATASOURCE_TYPE_ERROR)

        # Parse the JSON parameters
        params = json.loads(data_source.parameter)

        # Create a JDBC client
        jdbc_client = JdbcClientFactory.create_client(
            db_type=data_source_type.name,  # Assuming MySQL for example
            host=params.get("host"),
            port=params.get("port"),
            username=params.get("username"),
            password=params.get("password"),
            database=params.get("database"),
            extra_params=params.get("params", {})
        )

        try:

            data_list = JdbcClientFactory.run_query(jdbc_client, sql)
            return self.response_format(data=data_list)

        except DAONotFound as ex:
            logger.exception(ex)
            return self.handle_error(SolidUIErrorType.QUERY_METADATA_SQL_ERROR)