Connectors PostgreSQL

PostgreSQL data integration with Lima, in both directions.

PostgreSQL runs many operational applications and analytics stores. Lima reads it over JDBC in partitions, captures inserts, updates and deletes through logical replication (the pgoutput or wal2json plugins) and loads PostgreSQL targets with COPY and upserts.

SOURCEPostgreSQLPartitioned JDBC reads · Logical replica…LIMA BACKBONEExtractfull · incremental · change captureCheckevery row valid, or an exception with an…Transform and load150+ operators · Python · loads on the c…TARGETSPlanning applicationsKinaxis · o9 · Blue Yonder · IBP · OMPWarehouses and lakehousesSnowflake · Databricks · Fabric · S3 …Reporting and partnersPower BI · Tableau · EDI · files
How PostgreSQL fits the six Backbone steps. It is a source and a target: data comes out through the methods below, and results go back in with confirmation.
3
ways to read or write it
this connector
3
patterns supported
this connector
3
ways to run: SaaS, private cloud, on-premise
product
22 days
from contract to production
showcase estate
How Lima reads and writes PostgreSQL

Method by method.

Each method has a job. The first load uses the bulk method; the daily run uses the incremental or change-capture method; write-back uses the interface the system itself uses.

MethodWhat it doesWhen it is used
Partitioned JDBC readsReads tables in parallel slices by key ranges.First loads.
Logical replicationStreams changes from a replication slot.Change capture.
COPY + upsertBulk loads and applies changes.PostgreSQL as a target.
What it covers

Objects and patterns.

The objects are the tables, views or records Lima reaches through the methods above. The patterns say how a copy is made and kept current.

ObjectPlain meaning
Tables and viewsany schema
Replication slotsthe change feed position
PatternSupported
Full loadYes
IncrementalYes
Change capturelogical replication
Streaming—
Write-back—
What PostgreSQL expects

The landing model, and the hardest part.

ModelSchemas with typed tables and keys.LoadCOPY into staging, upsert by key.BackTargets can be read back.
The hardest part, in one sentence

Slot management so the change log never grows unbounded.

Before you start

Prerequisites, then four steps.

The prerequisites are what the team that runs PostgreSQL grants. The four steps are the same for every connector.

  • A user with SELECT (and REPLICATION for change capture)
  • wal_level = logical for change capture
  • A publication for the tables in scope
Register the connectionEndpoint, credentials from the vault, and the method. The connection is tested and a failed test names the cause.
Choose the objects and the patternPick tables or objects from the discovered schema, and the pattern: full, incremental, change capture or streaming.
Run the first load with checks onEvery row is valid or becomes an exception with an owner. The run ends with a count and a control total per table.
Schedule it on the business calendarA run window with a deadline; pause, resume and replay if a check trips; the report after every run.
What happens to a bad record

Incoming data = valid records + exception records. A row that fails a check is kept, routed to the person who owns it with a deadline, and replayed once fixed. The load carries on with the valid rows and the report says exactly what was held back. How exceptions work →

Terms on this page

Plain meanings.

ConnectorA packaged way to read or write one kind of system, with its authentication, methods and prerequisites described.
Full, incremental, change capture, streamingFour ways to make and keep a copy: read everything; read what changed since last time; read changes from a log as they happen; consume events in small batches.
Write-backWriting a result into the system that owns it through its released interface; the system's response is the confirmation.
Control totalThe sum of a key amount column compared between source and target, along with the row count, at the end of a run.
Exception recordA row that failed a check: kept, routed to an owner, replayed once fixed.
Questions

Asked about this connector.

Does Lima install anything in PostgreSQL?

Lima connects from outside through the interfaces listed above with credentials your administrators grant. Where a vendor requires its own agent or add-on for a method, the prerequisites say so.

How is load on PostgreSQL kept in check?

Parallel reads are capped and the cap is agreed with the team that runs the system. Large reads run inside an agreed run window. Change capture keeps the daily volume small.

What do we see when a run finishes?

A report per run: rows in, rows out, control totals and variance per table, the exceptions held back and who owns them, and whether the deadline was met.

Can we start small?

Yes. Most estates start with one source, one target and one dataset, then add tables and patterns on the same connection.

Try PostgreSQL on your own estate.

A trial connects this system, runs a first load and ends with a reconciliation report. Your administrators see the prerequisites before anything is installed.