mirror of
https://github.com/knex/knex.git
synced 2025-07-10 18:41:18 +00:00
160 lines
5.1 KiB
JavaScript
160 lines
5.1 KiB
JavaScript
'use strict';
|
|
|
|
const { expect } = require('chai');
|
|
const { TEST_TIMESTAMP } = require('../../util/constants');
|
|
const {
|
|
isSQLite,
|
|
isPostgreSQL,
|
|
isOracle,
|
|
isCockroachDB,
|
|
} = require('../../util/db-helpers');
|
|
|
|
module.exports = function (knex) {
|
|
describe('Deletes', function () {
|
|
it('should handle deletes', function () {
|
|
return knex('accounts')
|
|
.where('id', 1)
|
|
.del()
|
|
.testSql(function (tester) {
|
|
tester('mysql', 'delete from `accounts` where `id` = ?', [1], 1);
|
|
tester('pg', 'delete from "accounts" where "id" = ?', [1], 1);
|
|
tester(
|
|
'pg-redshift',
|
|
'delete from "accounts" where "id" = ?',
|
|
[1],
|
|
1
|
|
);
|
|
tester('sqlite3', 'delete from `accounts` where `id` = ?', [1], 1);
|
|
tester('oracledb', 'delete from "accounts" where "id" = ?', [1], 1);
|
|
tester(
|
|
'mssql',
|
|
'delete from [accounts] where [id] = ?;select @@rowcount',
|
|
[1],
|
|
1
|
|
);
|
|
});
|
|
});
|
|
|
|
it('should allow returning for deletes in postgresql and mssql', function () {
|
|
return knex('accounts')
|
|
.where('id', 2)
|
|
.del('*')
|
|
.testSql(function (tester) {
|
|
tester('mysql', 'delete from `accounts` where `id` = ?', [2], 1);
|
|
tester(
|
|
'pg',
|
|
'delete from "accounts" where "id" = ? returning *',
|
|
[2],
|
|
[
|
|
{
|
|
id: '2',
|
|
first_name: 'Test',
|
|
last_name: 'User',
|
|
email: 'test2@example.com',
|
|
logins: 1,
|
|
balance: 0,
|
|
about: 'Lorem ipsum Dolore labore incididunt enim.',
|
|
created_at: TEST_TIMESTAMP,
|
|
updated_at: TEST_TIMESTAMP,
|
|
phone: null,
|
|
},
|
|
]
|
|
);
|
|
tester(
|
|
'pg-redshift',
|
|
'delete from "accounts" where "id" = ?',
|
|
[2],
|
|
1
|
|
);
|
|
tester('sqlite3', 'delete from `accounts` where `id` = ?', [2], 1);
|
|
tester('oracledb', 'delete from "accounts" where "id" = ?', [2], 1);
|
|
tester(
|
|
'mssql',
|
|
'delete from [accounts] output deleted.* where [id] = ?',
|
|
[2],
|
|
[
|
|
{
|
|
id: '2',
|
|
first_name: 'Test',
|
|
last_name: 'User',
|
|
email: 'test2@example.com',
|
|
logins: 1,
|
|
balance: 0,
|
|
about: 'Lorem ipsum Dolore labore incididunt enim.',
|
|
created_at: TEST_TIMESTAMP,
|
|
updated_at: TEST_TIMESTAMP,
|
|
phone: null,
|
|
},
|
|
]
|
|
);
|
|
});
|
|
});
|
|
|
|
describe('Delete with join', function () {
|
|
it('should handle basic delete with join', async function () {
|
|
const query = knex('test_table_two')
|
|
.join('accounts', 'accounts.id', 'test_table_two.account_id')
|
|
.where({ 'accounts.email': 'test3@example.com' })
|
|
.del();
|
|
if (
|
|
isSQLite(knex) ||
|
|
isPostgreSQL(knex) ||
|
|
isCockroachDB(knex) ||
|
|
isOracle(knex)
|
|
) {
|
|
await expect(query).to.be.rejected;
|
|
return;
|
|
}
|
|
return query.testSql(function (tester) {
|
|
tester(
|
|
'mysql',
|
|
'delete `test_table_two` from `test_table_two` inner join `accounts` on `accounts`.`id` = `test_table_two`.`account_id` where `accounts`.`email` = ?',
|
|
['test3@example.com'],
|
|
1
|
|
);
|
|
tester(
|
|
'mssql',
|
|
'delete [test_table_two] from [test_table_two] inner join [accounts] on [accounts].[id] = [test_table_two].[account_id] where [accounts].[email] = ?;select @@rowcount',
|
|
['test3@example.com'],
|
|
1
|
|
);
|
|
});
|
|
});
|
|
it('should handle returning', async function () {
|
|
await knex('test_table_two').insert({
|
|
account_id: 4,
|
|
details: '',
|
|
status: 1,
|
|
});
|
|
const query = knex('test_table_two')
|
|
.join('accounts', 'accounts.id', 'test_table_two.account_id')
|
|
.where({ 'accounts.email': 'test4@example.com' })
|
|
.del('*');
|
|
if (
|
|
isSQLite(knex) ||
|
|
isPostgreSQL(knex) ||
|
|
isCockroachDB(knex) ||
|
|
isOracle(knex)
|
|
) {
|
|
await expect(query).to.be.rejected;
|
|
return;
|
|
}
|
|
return query.testSql(function (tester) {
|
|
tester(
|
|
'mysql',
|
|
'delete `test_table_two` from `test_table_two` inner join `accounts` on `accounts`.`id` = `test_table_two`.`account_id` where `accounts`.`email` = ?',
|
|
['test4@example.com'],
|
|
1
|
|
);
|
|
tester(
|
|
'mssql',
|
|
'delete [test_table_two] output deleted.* from [test_table_two] inner join [accounts] on [accounts].[id] = [test_table_two].[account_id] where [accounts].[email] = ?',
|
|
['test4@example.com'],
|
|
[{ id: 9, account_id: 4, details: '', status: 1 }]
|
|
);
|
|
});
|
|
});
|
|
});
|
|
});
|
|
};
|