PostgresSyncSchema

Classes > Sync.Postgres > PostgresSyncSchema

Schema management for PostgreSQL sync tables. Implements spec Appendix A (Complete Schema) for Postgres.

public static class PostgresSyncSchema

Methods

CreateSchema(NpgsqlConnection)

public static Result<bool, SyncError> CreateSchema(NpgsqlConnection connection)

Creates the sync schema tables in PostgreSQL.

Parameters:

Name Type Description
connection NpgsqlConnection PostgreSQL connection.

Returns: SyncError> - Success or database error.

GetOriginId(NpgsqlConnection)

public static Result<string, SyncError> GetOriginId(NpgsqlConnection connection)

Gets the origin ID from _sync_state.

Parameters:

Name Type Description
connection NpgsqlConnection PostgreSQL connection.

Returns: SyncError> - Origin ID or database error.

SetOriginId(NpgsqlConnection, string)

public static Result<bool, SyncError> SetOriginId(NpgsqlConnection connection, string originId)

Sets the origin ID in _sync_state.

Parameters:

Name Type Description
connection NpgsqlConnection PostgreSQL connection.
originId String Origin ID to set.

Returns: SyncError> - Success or database error.

InitializeOriginId(NpgsqlConnection)

public static string InitializeOriginId(NpgsqlConnection connection)

Initializes origin ID if not set.

Parameters:

Name Type Description
connection NpgsqlConnection PostgreSQL connection.

Returns: String - Origin ID (existing or new).