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).