Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.
import defineTable from './define-table'
import del from './delete'
import disconnect from './disconnect'
import dropReadModel from './drop-read-model'
import findOne from './find-one'
import find from './find'
import insert from './insert'
import rollbackTransaction from './rollback-transaction'
import searchToWhereExpression from './search-to-where-expression'
import updateToSetExpression from './update-to-set-expression'
import update from './update'
const memoryStore = {}
const store = { defineTable, find, findOne, count, insert, update, delete: del }
export default createAdapter.bind(null, {
...store,
connect: connect.bind(null, {
buildUpsertDocument,
convertBinaryRow,
searchToWhereExpression,
updateToSetExpression,
memoryStore,
...store,
SQLite,
tmp,
os
}),
beginTransaction,
commitTransaction,
rollbackTransaction,
dropReadModel,
import NeDB from 'nedb'
import createAdapter from 'resolve-readmodel-base'
import metaApi from './meta-api'
import storeApi from './store-api'
export default createAdapter.bind(null, {
metaApi: {
...metaApi,
connect: metaApi.connect.bind(null, NeDB)
},
storeApi
})
const store = { defineTable, find, findOne, count, insert, update, delete: del }
const connect = _connect.bind(null, {
RDSDataService,
escapeId,
escape,
buildUpsertDocument,
convertResultRow,
searchToWhereExpression,
updateToSetExpression,
executeStatement,
coercer,
...store
})
const createAdapter = _createAdapter.bind(null, {
...store,
connect,
beginTransaction,
commitTransaction,
rollbackTransaction,
dropReadModel,
disconnect
})
export default createAdapter
const pool = {
connect,
disconnect,
escapeId,
escape
import del from './delete'
import disconnect from './disconnect'
import dropReadModel from './drop-read-model'
import findOne from './find-one'
import find from './find'
import getTemplateDocument from './get-template-document'
import listReadModelTables from './list-read-model-tables'
import makeDocumentsSnapshots from './make-documents-snapshots'
import insert from './insert'
import rollbackTransaction from './rollback-transaction'
import update from './update'
import wrapSearchExpression from './wrap-search-expression'
const store = { defineTable, find, findOne, count, insert, update, delete: del }
export default createAdapter.bind(null, {
...store,
connect: connect.bind(null, {
MongoClient,
ObjectID,
wrapSearchExpression,
getTemplateDocument,
listReadModelTables,
makeDocumentsSnapshots,
...store
}),
beginTransaction,
commitTransaction,
rollbackTransaction,
dropReadModel,
disconnect
})
import count from './count'
import defineTable from './define-table'
import del from './delete'
import disconnect from './disconnect'
import dropReadModel from './drop-read-model'
import findOne from './find-one'
import find from './find'
import insert from './insert'
import rollbackTransaction from './rollback-transaction'
import searchToWhereExpression from './search-to-where-expression'
import updateToSetExpression from './update-to-set-expression'
import update from './update'
const store = { defineTable, find, findOne, count, insert, update, delete: del }
export default createAdapter.bind(null, {
...store,
connect: connect.bind(null, {
MySQL,
escapeId,
escape,
buildUpsertDocument,
convertBinaryRow,
searchToWhereExpression,
updateToSetExpression,
...store
}),
beginTransaction,
commitTransaction,
rollbackTransaction,
dropReadModel,
disconnect