An experimental helper which tracks the modification history of rows in postgres database tables, using git, based on the idea in this tweet.
The implementation uses plv8 to run JavaScript in postgres, with isomorphic-git and memfs to perform git operations in-memory.
To paraphrase @mayfer's twitter thread:
-
never have to worry about building edit/delete/undo/backup/recover type features, one generic git-backed [column] is enough
-
removes the need to keep additional SQL tables which keep logs of all edit histories.
-
makes event sourcing a lot more modular. instead of tons of tables storing custom events, every SQL update on a column also updates its git bundle, saved into a separate binary column
-
with just 1 extra column, you can add multiuser versioning to any indexed column!
-
how cool this will be for large JSON or other text blob c get overwritten a lot duringall commits are controlled by the main app, it's trivial to integrate commit authors directly into any regular application's user auth system
-
due to the git standard, this repo then can easily be fed into any generic git UI for all sorts of diffing, logging & visualizing
The easiest way to get started is to use the pre-baked sql files exported with the package:
npm install plv8-git
psql -c "
create extension if not exists plv8;
select plv8_version();
"
psql -f node_modules/plv8-git/queries/create-git-functions.sqlOr from javascript:
const sqlClient = getSqlClient()
const sql = require('plv8-git/queries').getGitFunctionsSql()
await sqlClient.runRawSql(sql)Note: for create extension plv8 to work the plv8.control file must exist on your database system. You can use the postgres-plv8 docker image for development (or production, if you really want to deploy a containerised database to production). Amazon RDS instances have the extension available, as does Azure Postgres 11.
This will have created three postgres functions: git_track, git_log and git_resolve.
git_track is a trigger function that can be added to any table, with a json column, default-named git:
create table test_table(
id int,
text text,
git json
);
create trigger test_table_git_track_trigger
before insert or update
on test_table for each row
execute procedure git_track();Now, whenever rows are inserted or updated into the test_table table, the git column will automatically be managed as a serialisation of the .git folder of an ephemeral git repo. All you need to do is insert/update as normal:
insert into test_table(id, text)
values(1, 'item 1 old content');
update test_table
set text = 'item 1 new content'
where id = 1;There's still just a single row in the test_table table, but the full history of it is tracked in the git column. The git_log function can be used to access the change history:
select git_log(git)
from test_table
where id = 1This query will return:
{
"git_log": [
{
"message": "test_table_git_track_trigger: BEFORE UPDATE ROW on public.test_table",
"author": "pguser ([email protected])",
"timestamp": "2000-12-25T12:00:00.000Z",
"oid": "[oid]",
"tags": [],
"changes": [
{
"field": "text",
"new": "item 1 new content",
"old": "item 1 old content"
}
]
},
{
"message": "test_table_git_track_trigger: BEFORE INSERT ROW on public.test_table",
"author": "pguser ([email protected])",
"timestamp": "2000-12-25T12:00:00.000Z",
"oid": "[oid]",
"tags": [],
"changes": [
{
"field": "id",
"new": 1
},
{
"field": "text",
"new": "item 1 old content"
}
]
}
]
}i.e. you can see the row's full history, in human- and machine-readable form, straight from the table.
To use existing git clients to get rich visual diffs, etc., you can simply pull the git field for a given row, and convert it into real files:
select git from test_table where id = 1{
"git": {
"/repo/.git/objects/8a/ed642bf5118b9d3c859bd4be35ecac75b6e873": "[byte array]",
"/repo/.git/objects/d0/ff5974b6aa52cf562bea5921840c032a860a91": "[byte array]",
"/repo/.git/objects/d8/4bdb34d4eeef4034d77e5403f850e35bc4a51b": "[byte array]",
"/repo/.git/objects/a4/16ea84421fa7e1351582da48235bac88380a33": "[byte array]",
"/repo/.git/objects/fb/d04e1aae9ce0b11a8946e2c9ac2619f7428a64": "[byte array]",
"/repo/.git/objects/a1/9a1584344c1f3783bff51524a5a4b86f2cc093": "[byte array]",
"/repo/.git/objects/8a/b31b5afaea56114427e1f01b81d001b079a0f5": "[byte array]",
"/repo/.git/refs/heads/main": "[byte array]",
"/repo/.git/config": "[byte array]",
"/repo/.git/HEAD": "[byte array]",
"/repo/.git/index": "[byte array]"
}
}This will return a json-formatted object, with keys corresponding to file system paths, and byte-array values as contents. Write them to disk using the CLI tool provided with this package:
GIT=$(psql -qAt -c "select git from test_table where id = 1")
node_modules/.bin/plv8-git write --input "$GIT" --output path/to/git/dirpath/to/git/dir will now be a valid git repository, with one file corresponding to each column in test_table. You can cd into it, and run commands like git log, or use your favourite git UI to inspect the history in as much detail as you'd like.
You can also take advantage of the git column to track deletions, by adding a delete hook:
create table deleted_history(
schemaname name,
tablename name,
identifier jsonb,
deleted_at timestamptz,
git json
);
create function test_table_track_deletion() returns trigger as
$$
begin
insert into deleted_history(schemaname, tablename, identifier, deleted_at, git)
values ('public', 'test_table', jsonb_build_object('id', OLD.id), now(), OLD.git);
return OLD;
end
$$
language plpgsql;
create trigger test_table_track_deletion_trigger
before delete
on test_table for each row
execute procedure test_table_track_deletion();You can now perform deletions as normal and they'll be automatically tracked in deleted_history:
delete from test_table
where id = 1The deleted_history table can be queried in the same was as the other tables:
select *
from deleted_history
where identifier->>'id' = '1'This will return something like:
{
"schemaname": "public",
"tablename": "test_table",
"identifier": {
"id": 1
},
"deleted_at": "2000-12-25T12:00:00.000Z",
"git": {
"/repo/.git/objects/8a/ed642bf5118b9d3c859bd4be35ecac75b6e873": "[byte array]",
"/repo/.git/objects/d0/ff5974b6aa52cf562bea5921840c032a860a91": "[byte array]",
"/repo/.git/objects/d8/4bdb34d4eeef4034d77e5403f850e35bc4a51b": "[byte array]",
"/repo/.git/objects/a4/16ea84421fa7e1351582da48235bac88380a33": "[byte array]",
"/repo/.git/objects/fb/d04e1aae9ce0b11a8946e2c9ac2619f7428a64": "[byte array]",
"/repo/.git/objects/a1/9a1584344c1f3783bff51524a5a4b86f2cc093": "[byte array]",
"/repo/.git/objects/8a/b31b5afaea56114427e1f01b81d001b079a0f5": "[byte array]",
"/repo/.git/refs/heads/main": "[byte array]",
"/repo/.git/config": "[byte array]",
"/repo/.git/HEAD": "[byte array]",
"/repo/.git/index": "[byte array]"
}
}You can use git_log again to get a readable history:
select git_log(git)
from deleted_history
where identifier->>'id' = '1'{
"git_log": [
{
"message": "test_table_git_track_trigger: BEFORE UPDATE ROW on public.test_table",
"author": "pguser ([email protected])",
"timestamp": "2000-12-25T12:00:00.000Z",
"oid": "[oid]",
"tags": [],
"changes": [
{
"field": "text",
"new": "item 1 new content",
"old": "item 1 old content"
}
]
},
{
"message": "test_table_git_track_trigger: BEFORE INSERT ROW on public.test_table",
"author": "pguser ([email protected])",
"timestamp": "2000-12-25T12:00:00.000Z",
"oid": "[oid]",
"tags": [],
"changes": [
{
"field": "id",
"new": 1
},
{
"field": "text",
"new": "item 1 old content"
}
]
}
]
}In this example, deleted_history is generic enough that it could be the "history" table for several other relations, since it uses columns schemaname and tablename, and identifier as the flexible JSONB data type to allow for different types of primary key. This avoids the overhead of needing a new _history table for every relation created - all the data, including history, is captured in the git column. The identifier column is only used for lookups.
You can pass a custom commit message and author by pre-loading the git property with commit details, which can include a commit message and user info:
insert into test_table(
id,
text,
git
)
values(
2,
'original value set by alice',
'{ "commit": { "message": "some custom message", "author": { "name": "Alice", "email": "[email protected]" } } }'
)select git_log(git)
from test_table
where id = 2{
"git_log": [
{
"message": "some custom message\\n\\ntest_table_git_track_trigger: BEFORE INSERT ROW on public.test_table",
"author": "Alice ([email protected])",
"timestamp": "2000-12-25T12:00:00.000Z",
"oid": "[oid]",
"tags": [],
"changes": [
{
"field": "id",
"new": 2
},
{
"field": "text",
"new": "original value set by alice"
}
]
}
]
}You can configure git using git_set_local_config or git_set_global_config:
select git_set_local_config('user.name', 'Bob');
select git_set_local_config('user.email', '[email protected]');
insert into test_table(id, text)
values(201, 'value set by bob')select git_log(git)
from test_table
where id = 201{
"git_log": [
{
"message": "test_table_git_track_trigger: BEFORE INSERT ROW on public.test_table",
"author": "Bob ([email protected])",
"timestamp": "2000-12-25T12:00:00.000Z",
"oid": "[oid]",
"tags": [],
"changes": [
{
"field": "id",
"new": 201
},
{
"field": "text",
"new": "value set by bob"
}
]
}
]
}Under the hood these use set_config with the is_local parameter respectively true/false for the local/global variants.
git_log also accepts a depth parameter to limit the amount of history that is fetched:
update test_table
set text = 'a new value set by admin',
git = '{ "commit": { "message": "Changed because the previous value was out-of-date" } }'
where id = 2select git_log(git, depth := 1)
from test_table
where id = 2{
"git_log": [
{
"message": "Changed because the previous value was out-of-date\\n\\ntest_table_git_track_trigger: BEFORE UPDATE ROW on public.test_table",
"author": "pguser ([email protected])",
"timestamp": "2000-12-25T12:00:00.000Z",
"oid": "[oid]",
"tags": [],
"changes": [
{
"field": "text",
"new": "a new value set by admin",
"old": "original value set by alice"
}
]
}
]
}By setting depth := 1, only the most recent change is returned.
You can pass tags to the git object. The below example uses a convention of tagging with the day, month, and year so it will later be easy to restore to previous versions:
insert into test_table(id, text, git)
values (3, 'item 3 xmas day value', '{ "git": { "tags": ["2000-12-25", "2000-12", "2000"] } }');
update test_table
set
text = 'item 3 boxing day value',
git = '{ "tags": ["2000-12-26", "2000-12", "2000"] }'
where id = 3;
update test_table
set
text = 'item 3 new year value',
git = '{ "tags": ["2001-01-01", "2001-01", "2001"] }'
where id = 3;Or, set them in git config as a colon-separated list:
select git_set_local_config('tags', 'your_app_request_id=1234:your_app_trace_id=5678');
update test_table
set text = 'item 3 yet another value'
where id = 3;git_resolve gives you a json representation of a prior version of a row, which can be used for backup and restore. The first argument is a git json value, the second value is a valid git ref string (e.g. a git oid returned by git_log, or HEAD, or main. Note that an issue with isomorphic-git means that you can't currently pass values like HEAD~1 here).
Combine it with git_log to get a previous version - the below query uses ->1->>'oid' to get the oid from the second item in the log array:
select git_resolve(git, ref := git_log(git)->1->>'oid')
from test_table
where id = 2{
"git_resolve": {
"id": 2,
"text": "original value set by alice"
}
}This can be used in an update query to revert a change:
update test_table set (id, text) =
(
select id, text
from json_populate_record(
null::test_table,
git_resolve(git, ref := git_log(git)->1->>'oid')
)
)
where id = 2
returning id, text{
"id": 2,
"text": "original value set by alice"
}If you used tags as described above, you can take advantage of them to restore to a known-good state easily:
select git_log(git)
from test_table
where id = 3[
{
"git_log": [
{
"message": "test_table_git_track_trigger: BEFORE UPDATE ROW on public.test_table",
"author": "pguser ([email protected])",
"timestamp": "2000-12-25T12:00:00.000Z",
"oid": "[oid]",
"tags": [
"your_app_request_id=1234",
"your_app_trace_id=5678"
],
"changes": [
{
"field": "text",
"new": "item 3 yet another value",
"old": "item 3 new year value"
}
]
},
{
"message": "test_table_git_track_trigger: BEFORE UPDATE ROW on public.test_table",
"author": "pguser ([email protected])",
"timestamp": "2000-12-25T12:00:00.000Z",
"oid": "[oid]",
"tags": [
"2001",
"2001-01",
"2001-01-01"
],
"changes": [
{
"field": "text",
"new": "item 3 new year value",
"old": "item 3 boxing day value"
}
]
},
{
"message": "test_table_git_track_trigger: BEFORE UPDATE ROW on public.test_table",
"author": "pguser ([email protected])",
"timestamp": "2000-12-25T12:00:00.000Z",
"oid": "[oid]",
"tags": [
"2000",
"2000-12",
"2000-12-26"
],
"changes": [
{
"field": "text",
"new": "item 3 boxing day value",
"old": "item 3 xmas day value"
}
]
},
{
"message": "test_table_git_track_trigger: BEFORE INSERT ROW on public.test_table",
"author": "pguser ([email protected])",
"timestamp": "2000-12-25T12:00:00.000Z",
"oid": "[oid]",
"tags": [],
"changes": [
{
"field": "id",
"new": 3
},
{
"field": "text",
"new": "item 3 xmas day value"
}
]
}
]
}
]update test_table set (id, text) =
(
select id, text
from json_populate_record(
null::test_table,
git_resolve(git, ref := '2000-12')
)
)
where id = 3
returning id, text{
"id": 3,
"text": "item 3 boxing day value"
}update test_table set (id, text) =
(
select id, text
from json_populate_record(
null::test_table,
git_resolve(git, ref := 'your_app_request_id=1234')
)
)
where id = 3
returning id, text{
"id": 3,
"text": "item 3 yet another value"
}A similar technique can restore a deleted item:
insert into test_table
select * from json_populate_record(
null::test_table,
(
select git_resolve(git, ref := 'HEAD')
from deleted_history
where tablename = 'test_table' and identifier->>'id' = '1'
)
)
returning id, text{
"id": 1,
"text": "item 1 new content"
}History can be tracked even on pre-existing tables which already have a git column used for something else:
create table repos(
id int,
name text,
git text -- the repo clone url
);Any column with type json can be used, by passing the column name when creating a trigger:
alter table repos
add column my_custom_plv8_git_column json;
create trigger repos_git_track_trigger
before insert or update
on repos for each row
execute procedure git_track('my_custom_plv8_git_column');
insert into repos(id, name, git)
values (1, 'plv8-git', 'https://github.com/mmkal/plv8-git.git');select git_log(my_custom_plv8_git_column)
from repos
where git = 'https://github.com/mmkal/plv8-git.git'{
"git_log": [
{
"message": "repos_git_track_trigger: BEFORE INSERT ROW on public.repos",
"author": "pguser ([email protected])",
"timestamp": "2000-12-25T12:00:00.000Z",
"oid": "[oid]",
"tags": [],
"changes": [
{
"field": "git",
"new": "https://github.com/mmkal/plv8-git.git"
},
{
"field": "id",
"new": 1
},
{
"field": "name",
"new": "plv8-git"
}
]
}
]
}- This library is experimental, and hasn't been pressure-tested. There may well be edge-cases where it falls down.
- It hasn't been performance-tested yet. It works well for rows with small, easily-json-stringifiable data. Large, frequently updated rows may hit issues.
- It currently uses the
JSONdata type to store a serialised copy of the.gitrepo folder. This can likely be optimised to useBYTEAor another data type. - It uses several tools that were not built with each other in mind (although each is well-designed and flexible enough for them to play nice without too many problems). See the implementation section
- It's still in v0, so breaking changes may occur.
At its core, this library bundles isomorphic-git and memfs to produce an entirely in-memory, synchronous git implementation which can run inside postgres's plv8 engine. A few modifications are applied to each:
Since plv8 triggers need to return values synchronously, but isomorphic-git uses promises extensively, a shim of the global Promise object was created called SyncPromise. This has the same API as Promise, but its callbacks are executed immediately.
To avoid the event-loop, all async-await code in isomorphic-git is transformed to .then, .catch etc. by babel-plugin-transform-async-to-promises. async-lock, which is a dependency of isomorphic-git, is also shimmed to bypass its locking mechanism which relies on timers - it's not necessary anyway, since all git operations take place on an ephemeral, in-memory, synchronous filesystem.
memfs is also shimmed before being passed to isomorphic-git to replace its promise-based operations with sync ones.
These libraries are bundled using webpack into a standalone module with no dependencies. The source code for this bundle is copied into a sql file by generate-queries, so that it can be used to define a postgres function with plv8.