diff --git a/lib/adapter.js b/lib/adapter.js index 5ef54572..ff284a4c 100644 --- a/lib/adapter.js +++ b/lib/adapter.js @@ -140,8 +140,10 @@ module.exports = (function() { // Store the connection connections[connection.identity] = { config: connection, + collections: collections, schema: schema, - version: version + version: version, + processor: new Processor(schema) // Cache processor for each connection to avoid deepClone of schema }; // Always call describe @@ -517,7 +519,7 @@ module.exports = (function() { // Build up a SQL Query var schema = connectionObject.schema; - var processor = new Processor(schema); + var processor = connectionObject.processor; // use cached processor // Mixin WL Next connection overrides to sqlOptions var overrides = connectionOverrides[connectionName] || {}; @@ -608,7 +610,7 @@ module.exports = (function() { // Build up a SQL Query var schema = connectionObject.schema; - var processor = new Processor(schema); + var processor = connectionObject.processor; // use cached processor // Mixin WL Next connection overrides to sqlOptions var overrides = connectionOverrides[connectionName] || {}; @@ -1080,7 +1082,7 @@ module.exports = (function() { // Build Query var _schema = connectionObject.schema; - var processor = new Processor(_schema); + var processor = connectionObject.processor; // use cached processor // Mixin WL Next connection overrides to sqlOptions var overrides = connectionOverrides[connectionName] || {}; @@ -1143,7 +1145,7 @@ module.exports = (function() { // Build Query var _schema = connectionObject.schema; - var processor = new Processor(_schema); + var processor = connectionObject.processor; // use cached processor // Mixin WL Next connection overrides to sqlOptions var overrides = connectionOverrides[connectionName] || {}; @@ -1258,7 +1260,7 @@ module.exports = (function() { var tableName = table; var _schema = connectionObject.schema; - var processor = new Processor(_schema); + var processor = connectionObject.processor; // use cached processor // Mixin WL Next connection overrides to sqlOptions var overrides = connectionOverrides[connectionName] || {};