joe/kami-parse-server
Public Access
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Update PostgresStorageAdapter.js (#4094)

Browse Source 
* proper use of the connections
* proper integrity: creating tables within a single transaction.
This commit is contained in:
Vitaly Tomilov
2017-08-23 16:34:57 +01:00
committed by Florent Vilmart
parent c6546218f4
commit 2b4c7570ea
1 changed files with 6 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/Adapters/Storage/Postgres/PostgresStorageAdapter.js
View File

@@ -668,10 +668,12 @@ export class PostgresStorageAdapter {
throw error; throw error;
} }
}).then(() => { }).then(() => {
// Create the relation tables return conn.tx('create-relation-tables', t => {
return Promise.all(relations.map((fieldName) => { const queries = relations.map((fieldName) => {
return conn.none('CREATE TABLE IF NOT EXISTS $<joinTable:name> ("relatedId" varChar(120), "owningId" varChar(120), PRIMARY KEY("relatedId", "owningId") )', {joinTable: `_Join:${fieldName}:${className}`}); return t.none('CREATE TABLE IF NOT EXISTS $<joinTable:name> ("relatedId" varChar(120), "owningId" varChar(120), PRIMARY KEY("relatedId", "owningId") )', {joinTable: `_Join:${fieldName}:${className}`});
})); });
return t.batch(queries);
});
}); });
} }