mirror of
https://github.com/knex/knex.git
synced 2025-06-26 22:00:25 +00:00
43 lines
1.2 KiB
JavaScript
43 lines
1.2 KiB
JavaScript
const { isObject } = require('../util/is');
|
|
|
|
// Compiles a callback using the query builder.
|
|
function compileCallback(callback, method, client, bindingsHolder) {
|
|
// Build the callback
|
|
const builder = client.queryBuilder();
|
|
callback.call(builder, builder);
|
|
|
|
// Compile the callback, using the current formatter (to track all bindings).
|
|
const compiler = client.queryCompiler(builder, bindingsHolder.bindings);
|
|
|
|
// Return the compiled & parameterized sql.
|
|
return compiler.toSQL(method || builder._method || 'select');
|
|
}
|
|
|
|
function wrapAsIdentifier(value, builder, client) {
|
|
const queryContext = builder.queryContext();
|
|
return client.wrapIdentifier((value || '').trim(), queryContext);
|
|
}
|
|
|
|
function formatDefault(value, type, client) {
|
|
if (value === void 0) {
|
|
return '';
|
|
} else if (value === null) {
|
|
return 'null';
|
|
} else if (value && value.isRawInstance) {
|
|
return value.toQuery();
|
|
} else if (type === 'bool') {
|
|
if (value === 'false') value = 0;
|
|
return `'${value ? 1 : 0}'`;
|
|
} else if ((type === 'json' || type === 'jsonb') && isObject(value)) {
|
|
return `'${JSON.stringify(value)}'`;
|
|
} else {
|
|
return client._escapeBinding(value.toString());
|
|
}
|
|
}
|
|
|
|
module.exports = {
|
|
compileCallback,
|
|
wrapAsIdentifier,
|
|
formatDefault,
|
|
};
|