Bump the YSQL Catalog Version

				
					CREATE OR REPLACE FUNCTION yb_bump_catalog_version(
  p_dbname   text,
  p_breaking boolean DEFAULT true
) RETURNS void
LANGUAGE plpgsql
SECURITY DEFINER
SET search_path = pg_catalog
AS $$
DECLARE
  v_prev_guc        text;
  v_db_oid          oid;
  current_before    bigint;
  breaking_before   bigint;
  current_after     bigint;
  breaking_after    bigint;
BEGIN
  SELECT d.oid INTO v_db_oid
  FROM pg_database d
  WHERE d.datname = p_dbname;
  IF NOT FOUND THEN
    RAISE EXCEPTION 'Database % not found', p_dbname;
  END IF;

  SELECT c.current_version, c.last_breaking_version
    INTO current_before, breaking_before
  FROM pg_yb_catalog_version c
  WHERE c.db_oid = v_db_oid;

  v_prev_guc := current_setting('yb_non_ddl_txn_for_sys_tables_allowed', true);
  PERFORM set_config('yb_non_ddl_txn_for_sys_tables_allowed', '1', false);

  BEGIN
    UPDATE pg_yb_catalog_version c
       SET current_version       = c.current_version + 1,
           last_breaking_version = c.last_breaking_version + CASE WHEN p_breaking THEN 1 ELSE 0 END
     WHERE c.db_oid = v_db_oid
     RETURNING c.current_version, c.last_breaking_version
       INTO current_after, breaking_after;
  EXCEPTION WHEN OTHERS THEN
    PERFORM set_config('yb_non_ddl_txn_for_sys_tables_allowed', COALESCE(v_prev_guc,'0'), false);
    RAISE;
  END;

  PERFORM set_config('yb_non_ddl_txn_for_sys_tables_allowed', COALESCE(v_prev_guc,'0'), false);

  RAISE NOTICE 'Bumped catalog version for % (oid=%) from (current=%, breaking=%) to (current=%, breaking=%)',
               p_dbname, v_db_oid, current_before, breaking_before, current_after, breaking_after;
END;
$$;