@databases/shared
Advanced tools
Comparing version 3.0.0 to 3.0.1-canary-1851
@@ -12,3 +12,3 @@ "use strict"; | ||
this._factories = factories; | ||
this._lock = lock_1.createLock(driver.acquireLockTimeoutMilliseconds); | ||
this._lock = (0, lock_1.createLock)(driver.acquireLockTimeoutMilliseconds); | ||
} | ||
@@ -28,3 +28,3 @@ _throwIfDisposed() { | ||
try { | ||
return await utils_1.txInternal(this._driver, this._factories, fn, options); | ||
return await (0, utils_1.txInternal)(this._driver, this._factories, fn, options); | ||
} | ||
@@ -36,3 +36,3 @@ finally { | ||
async query(query) { | ||
utils_1.assertSql(query); | ||
(0, utils_1.assertSql)(query); | ||
this._throwIfDisposed(); | ||
@@ -44,3 +44,3 @@ if (Array.isArray(query)) { | ||
try { | ||
return await utils_1.queryInternal(this._driver, query, utils_1.executeAndReturnAll); | ||
return await (0, utils_1.queryInternal)(this._driver, query, utils_1.executeAndReturnAll); | ||
} | ||
@@ -54,3 +54,3 @@ finally { | ||
try { | ||
return await utils_1.queryInternal(this._driver, split_sql_query_1.default(query), utils_1.executeAndReturnLast); | ||
return await (0, utils_1.queryInternal)(this._driver, (0, split_sql_query_1.default)(query), utils_1.executeAndReturnLast); | ||
} | ||
@@ -66,3 +66,3 @@ finally { | ||
async *queryStream(query, options) { | ||
utils_1.assertSql(query); | ||
(0, utils_1.assertSql)(query); | ||
this._throwIfDisposed(); | ||
@@ -69,0 +69,0 @@ await this._lock.acquireLock(); |
@@ -12,3 +12,3 @@ "use strict"; | ||
this._disposed = false; | ||
this._pool = connection_pool_1.default(options); | ||
this._pool = (0, connection_pool_1.default)(options); | ||
this._factories = factories; | ||
@@ -56,3 +56,3 @@ } | ||
async query(query) { | ||
utils_1.assertSql(query); | ||
(0, utils_1.assertSql)(query); | ||
this._throwIfDisposed(); | ||
@@ -65,3 +65,3 @@ if (Array.isArray(query)) { | ||
else { | ||
return this._withDriverFromPool(utils_1.queryInternal, split_sql_query_1.default(query), utils_1.executeAndReturnLast); | ||
return this._withDriverFromPool(utils_1.queryInternal, (0, split_sql_query_1.default)(query), utils_1.executeAndReturnLast); | ||
} | ||
@@ -73,3 +73,3 @@ } | ||
async *queryStream(query, options) { | ||
utils_1.assertSql(query); | ||
(0, utils_1.assertSql)(query); | ||
this._throwIfDisposed(); | ||
@@ -76,0 +76,0 @@ const poolRecord = await this._pool.getConnection(); |
@@ -13,3 +13,3 @@ "use strict"; | ||
this._factories = factories; | ||
this._lock = lock_1.createLock(driver.acquireLockTimeoutMilliseconds); | ||
this._lock = (0, lock_1.createLock)(driver.acquireLockTimeoutMilliseconds); | ||
this._parentContext = parentContext; | ||
@@ -50,3 +50,3 @@ } | ||
async query(query) { | ||
utils_1.assertSql(query); | ||
(0, utils_1.assertSql)(query); | ||
this._throwIfDisposed(); | ||
@@ -61,3 +61,3 @@ await this._lock.acquireLock(); | ||
else { | ||
return await this._driver.executeAndReturnLast(split_sql_query_1.default(query)); | ||
return await this._driver.executeAndReturnLast((0, split_sql_query_1.default)(query)); | ||
} | ||
@@ -73,3 +73,3 @@ } | ||
async *queryStream(query, options) { | ||
utils_1.assertSql(query); | ||
(0, utils_1.assertSql)(query); | ||
this._throwIfDisposed(); | ||
@@ -76,0 +76,0 @@ await this._lock.acquireLock(); |
@@ -8,3 +8,3 @@ "use strict"; | ||
for (const q of query) { | ||
if (!web_1.isSqlQuery(q)) { | ||
if (!(0, web_1.isSqlQuery)(q)) { | ||
throw new Error('Invalid query, you must use @databases/sql to create your queries.'); | ||
@@ -15,3 +15,3 @@ } | ||
else { | ||
if (!web_1.isSqlQuery(query)) { | ||
if (!(0, web_1.isSqlQuery)(query)) { | ||
throw new Error('Invalid query, you must use @databases/sql to create your queries.'); | ||
@@ -62,4 +62,4 @@ } | ||
let failureCount = 0; | ||
await driver.beginTransaction(options); | ||
while (true) { | ||
await driver.beginTransaction(options); | ||
const postCommitSteps = []; | ||
@@ -66,0 +66,0 @@ const tx = factories.createTransaction(driver, { |
{ | ||
"name": "@databases/shared", | ||
"version": "3.0.0", | ||
"version": "3.0.1-canary-1851", | ||
"description": "", | ||
@@ -8,7 +8,7 @@ "main": "./lib/index.js", | ||
"dependencies": { | ||
"@databases/connection-pool": "^1.0.0", | ||
"@databases/lock": "^2.0.0", | ||
"@databases/queue": "^1.0.0", | ||
"@databases/split-sql-query": "^1.0.1", | ||
"@databases/sql": "^3.0.0", | ||
"@databases/connection-pool": "1.1.0", | ||
"@databases/lock": "2.1.0", | ||
"@databases/queue": "1.0.0", | ||
"@databases/split-sql-query": "1.0.3", | ||
"@databases/sql": "3.2.0", | ||
"cuid": "^2.1.8" | ||
@@ -15,0 +15,0 @@ }, |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
No v1
QualityPackage is not semver >=1. This means it is not stable and does not support ^ ranges.
Found 1 instance in 1 package
76672
2
+ Added@databases/queue@1.0.0(transitive)
+ Added@databases/split-sql-query@1.0.3(transitive)
+ Added@databases/sql@3.2.0(transitive)
- Removed@databases/queue@1.0.1(transitive)
- Removed@databases/split-sql-query@1.0.4(transitive)
- Removed@databases/sql@3.3.0(transitive)
Updated@databases/lock@2.1.0
Updated@databases/queue@1.0.0
Updated@databases/sql@3.2.0