Method query_sql

solidui/views/metadata/api.py:154–188

(self)

    @expose('/querySql', methods=("GET",))
    @safe
    def query_sql(self) -> FlaskResponse:
        data_source_name = request.args.get('dataSourceName')
        sql = request.args.get('sql')

        # Call the service method to get table data. You need to implement this logic
        data_source = DataSourceDAO.get_data_source_name(data_source_name)
        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)

    @expose('/querySql/id', methods=("GET",))
    @safe