Skip to content

Commit fe8d308

Browse files
committed
do not cache adapter
1 parent e33b212 commit fe8d308

File tree

1 file changed

+7
-59
lines changed

1 file changed

+7
-59
lines changed

src/client/index.js

Lines changed: 7 additions & 59 deletions
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,6 @@ const createAxiosInterceptor = require('./axiosInterceptor');
1212
const flags = require('../flags');
1313

1414
function rdbClient(options = {}) {
15-
let cachedAdapter;
1615
flags.useLazyDefaults = false;
1716
if (options.pg)
1817
options = { db: options };
@@ -248,14 +247,7 @@ function rdbClient(options = {}) {
248247
path: 'aggregate',
249248
args
250249
});
251-
let adapter;
252-
if (cachedAdapter)
253-
adapter = cachedAdapter;
254-
else {
255-
adapter = netAdapter(url, tableName, { axios: axiosInterceptor, tableOptions });
256-
cachedAdapter = adapter;
257-
258-
}
250+
let adapter = netAdapter(url, tableName, { axios: axiosInterceptor, tableOptions });
259251
return adapter.post(body);
260252
}
261253

@@ -265,14 +257,7 @@ function rdbClient(options = {}) {
265257
path: 'count',
266258
args
267259
});
268-
let adapter;
269-
if (cachedAdapter)
270-
adapter = cachedAdapter;
271-
else {
272-
adapter = netAdapter(url, tableName, { axios: axiosInterceptor, tableOptions });
273-
cachedAdapter = adapter;
274-
275-
}
260+
let adapter = netAdapter(url, tableName, { axios: axiosInterceptor, tableOptions });
276261
return adapter.post(body);
277262
}
278263

@@ -308,15 +293,7 @@ function rdbClient(options = {}) {
308293
path: 'getManyDto',
309294
args
310295
});
311-
312-
let adapter;
313-
if (cachedAdapter)
314-
adapter = cachedAdapter;
315-
else {
316-
adapter = netAdapter(url, tableName, { axios: axiosInterceptor, tableOptions });
317-
cachedAdapter = adapter;
318-
319-
}
296+
let adapter = netAdapter(url, tableName, { axios: axiosInterceptor, tableOptions });
320297
return adapter.post(body);
321298
}
322299

@@ -393,14 +370,7 @@ function rdbClient(options = {}) {
393370
path: 'delete',
394371
args
395372
});
396-
let adapter;
397-
if (cachedAdapter)
398-
adapter = cachedAdapter;
399-
else {
400-
adapter = netAdapter(url, tableName, { axios: axiosInterceptor, tableOptions });
401-
cachedAdapter = adapter;
402-
403-
}
373+
let adapter = netAdapter(url, tableName, { axios: axiosInterceptor, tableOptions });
404374
return adapter.post(body);
405375
}
406376

@@ -410,14 +380,7 @@ function rdbClient(options = {}) {
410380
path: 'deleteCascade',
411381
args
412382
});
413-
let adapter;
414-
if (cachedAdapter)
415-
adapter = cachedAdapter;
416-
else {
417-
adapter = netAdapter(url, tableName, { axios: axiosInterceptor, tableOptions });
418-
cachedAdapter = adapter;
419-
420-
}
383+
let adapter = netAdapter(url, tableName, { axios: axiosInterceptor, tableOptions });
421384
return adapter.post(body);
422385
}
423386

@@ -427,14 +390,7 @@ function rdbClient(options = {}) {
427390
path: 'update',
428391
args
429392
});
430-
let adapter;
431-
if (cachedAdapter)
432-
adapter = cachedAdapter;
433-
else {
434-
adapter = netAdapter(url, tableName, { axios: axiosInterceptor, tableOptions });
435-
cachedAdapter = adapter;
436-
437-
}
393+
let adapter = netAdapter(url, tableName, { axios: axiosInterceptor, tableOptions });
438394
const result = await adapter.post(body);
439395
if (strategy)
440396
return proxify(result, strategy);
@@ -446,14 +402,7 @@ function rdbClient(options = {}) {
446402
path: 'replace',
447403
args
448404
});
449-
let adapter;
450-
if (cachedAdapter)
451-
adapter = cachedAdapter;
452-
else {
453-
adapter = netAdapter(url, tableName, { axios: axiosInterceptor, tableOptions });
454-
cachedAdapter = adapter;
455-
456-
}
405+
let adapter = netAdapter(url, tableName, { axios: axiosInterceptor, tableOptions });
457406
const result = await adapter.post(body);
458407
if (strategy)
459408
return proxify(result, strategy);
@@ -616,7 +565,6 @@ function rdbClient(options = {}) {
616565
if (meta)
617566
return meta;
618567
let adapter = netAdapter(url, tableName, { axios: axiosInterceptor, tableOptions });
619-
cachedAdapter = adapter;
620568
meta = await adapter.get();
621569

622570
while (hasUnresolved(meta)) {

0 commit comments

Comments
 (0)