def METHOD_NAME(self, query, request_env, mindsdb_env, session):
    database = request_env['database']
    project_name = request_env['database']
    if database == 'config':
        # return nothing
        return {
            'cursor': {
                'id': Int64(0),
                'ns': f"{database}.$cmd.{query['find']}",
                'firstBatch': []
            },
            'ok': 1
        }
    # system queries
    elif query['find'] == 'system.version':
        # For studio3t
        data = [{
            "_id": "featureCompatibilityVersion",
            "version": "3.6"
        }]
        cursor = {
            'id': Int64(0),
            'ns': f"system.version.$cmd.{query['find']}",
            'firstBatch': data
        }
        return {
            'cursor': cursor,
            'ok': 1
        }
    elif query['find'] == 'ml_engines':
        ast_query = Show('ml_engines')
    else:
        ast_query = find_to_ast(query, database)
    # add _id for objects
    table_name = None
    obj_idx = {}
    if isinstance(ast_query, Select) and ast_query.from_table is not None:
        if isinstance(ast_query.from_table, Identifier):
            table_name = ast_query.from_table.parts[-1].lower()
            if table_name == 'models' or table_name == 'models_versions':
                models = mindsdb_env['model_controller'].get_models(
                    ml_handler_name=None,
                    project_name=project_name
                )
                for model in models:
                    obj_idx[model['name']] = model['id']
                # is select from model without where
                if table_name in obj_idx and ast_query.where is None:
                    # replace query to describe model
                    ast_query = Describe(ast_query.from_table)
            elif table_name == 'jobs':
                jobs_controller = JobsController()
                for job in jobs_controller.get_list(project_name):
                    obj_idx[job['name']] = job['id']
    data = run_sql_command(request_env, ast_query)
    if table_name == 'models' or table_name == 'models_versions':
        # for models and models_versions _id is:
        #   - first 20 bytes is version
        #   - next bytes is model id
        for row in data:
            model_id = obj_idx.get(row.get('NAME'))
            if model_id is not None:
                obj_id = model_id << 20
                if table_name == 'models_versions':
                    obj_id += row.get('VERSION', 0)
                row['_id'] = helpers.int_to_objectid(obj_id)
    elif table_name == 'jobs':
        for row in data:
            obj_id = obj_idx.get(row.get('NAME'))
            if obj_id is not None:
                row['_id'] = helpers.int_to_objectid(obj_id)
    db = mindsdb_env['config']['api']['mongodb']['database']
    cursor = {
        'id': Int64(0),
        'ns': f"{db}.$cmd.{query['find']}",
        'firstBatch': data
    }
    return {
        'cursor': cursor,
        'ok': 1
    }