forked from brianc/node-sql
-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathindex-tests.js
More file actions
214 lines (173 loc) · 9.18 KB
/
index-tests.js
File metadata and controls
214 lines (173 loc) · 9.18 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
'use strict';
var assert = require('assert');
var sql = require('../lib');
var user = sql.define({
name: 'user',
columns: ['id', 'email']
});
suite('index', function() {
test('unknown dialect throws exception', function() {
assert.throws(function() {
sql.setDialect('asdf');
});
});
test('stores the default dialect\'s name if none has been passed', function() {
assert.equal(sql.create().dialectName, 'postgres');
});
test('stores the sqlite dialect', function() {
assert.equal(sql.create('sqlite').dialectName, 'sqlite');
});
test('stores the mysql dialect', function() {
assert.equal(sql.create('mysql').dialectName, 'mysql');
});
test('stores the mssql dialect', function() {
assert.equal(sql.create('mssql').dialectName, 'mssql');
});
test('stores the oracle dialect', function() {
assert.equal(sql.create('oracle').dialectName, 'oracle');
});
test('can create a query using the default dialect', function() {
var query = sql.select(user.id).from(user).where(user.email.equals('brian.m.carlson@gmail.com')).toQuery();
assert.equal(query.text, 'SELECT "user"."id" FROM "user" WHERE ("user"."email" = $1)');
assert.equal(query.values[0], 'brian.m.carlson@gmail.com');
});
test('setting dialect to postgres works', function() {
sql.setDialect('postgres');
var query = sql.select(user.id).from(user).where(user.email.equals('brian.m.carlson@gmail.com')).toQuery();
assert.equal(query.text, 'SELECT "user"."id" FROM "user" WHERE ("user"."email" = $1)');
assert.equal(query.values[0], 'brian.m.carlson@gmail.com');
});
test('sql.create creates an instance with a new dialect', function() {
var mysql = sql.create('mysql');
var query = mysql.select(user.id).from(user).where(user.email.equals('brian.m.carlson@gmail.com')).toQuery();
assert.equal(query.text, 'SELECT `user`.`id` FROM `user` WHERE (`user`.`email` = ?)');
assert.equal(query.values[0], 'brian.m.carlson@gmail.com');
});
test('sql.define for parallel dialects work independently', function() {
var mssql = sql.create('mssql');
var mysql = sql.create('mysql');
var postgres = sql.create('postgres');
var sqlite = sql.create('sqlite');
var oracle = sql.create('oracle');
var mssqlTable = mssql.define({name: 'table', columns: ['column']});
var mysqlTable = mysql.define({name: 'table', columns: ['column']});
var postgresTable = postgres.define({name: 'table', columns: ['column']});
var sqliteTable = sqlite.define({name: 'table', columns: ['column']});
var oracleTable = oracle.define({name: 'table', columns: ['column']});
assert.equal(mysqlTable.sql, mysql);
assert.equal(postgresTable.sql, postgres);
assert.equal(sqliteTable.sql, sqlite);
assert.equal(mssqlTable.sql, mssql);
assert.equal(oracleTable.sql, oracle);
});
test('using Sql as a class', function() {
var Sql = sql.Sql;
var mssql = new Sql('mssql');
var mysql = new Sql('mysql');
var postgres = new Sql('postgres');
var sqlite = new Sql('sqlite');
var oracle = new Sql('oracle');
assert.equal(mysql.dialect, require(__dirname + '/../lib/dialect/mysql'));
assert.equal(postgres.dialect, require(__dirname + '/../lib/dialect/postgres'));
assert.equal(sqlite.dialect, require(__dirname + '/../lib/dialect/sqlite'));
assert.equal(mssql.dialect, require(__dirname + '/../lib/dialect/mssql'));
assert.equal(oracle.dialect, require(__dirname + '/../lib/dialect/oracle'));
});
test('override dialect for toQuery using dialect name', function() {
var Sql = sql.Sql;
var mssql = new Sql('mssql');
var mysql = new Sql('mysql');
var postgres = new Sql('postgres');
var sqlite = new Sql('sqlite');
var oracle = new Sql('oracle');
var sqliteQuery = mysql.select(user.id).from(user).where(user.email.equals('brian.m.carlson@gmail.com')).toQuery('sqlite');
var postgresQuery = sqlite.select(user.id).from(user).where(user.email.equals('brian.m.carlson@gmail.com')).toQuery('postgres');
var mysqlQuery = postgres.select(user.id).from(user).where(user.email.equals('brian.m.carlson@gmail.com')).toQuery('mysql');
var mssqlQuery = mysql.select(user.id).from(user).where(user.email.equals('brian.m.carlson@gmail.com')).toQuery('mssql');
var oracleQuery = oracle.select(user.id).from(user).where(user.email.equals('brian.m.carlson@gmail.com')).toQuery('oracle');
var values = ['brian.m.carlson@gmail.com'];
assert.equal(sqliteQuery.text, 'SELECT "user"."id" FROM "user" WHERE ("user"."email" = $1)');
assert.deepEqual(sqliteQuery.values, values);
assert.equal(postgresQuery.text, 'SELECT "user"."id" FROM "user" WHERE ("user"."email" = $1)');
assert.deepEqual(postgresQuery.values, values);
assert.equal(mysqlQuery.text, 'SELECT `user`.`id` FROM `user` WHERE (`user`.`email` = ?)');
assert.deepEqual(mysqlQuery.values, values);
assert.equal(mssqlQuery.text, 'SELECT [user].[id] FROM [user] WHERE ([user].[email] = @1)');
assert.deepEqual(mssqlQuery.values, values);
assert.equal(oracleQuery.text, 'SELECT "user"."id" FROM "user" WHERE ("user"."email" = :1)');
assert.deepEqual(oracleQuery.values, values);
});
test('override dialect for toQuery using invalid dialect name', function() {
var query = sql.select(user.id).from(user);
assert.throws(function() {
query.toQuery('invalid');
});
});
test('using named queries with toNamedQuery', function() {
var query = sql.select(user.id).from(user).where(user.email.equals('brian.m.carlson@gmail.com')).toNamedQuery('users');
assert.equal(query.text, 'SELECT "user"."id" FROM "user" WHERE ("user"."email" = $1)');
assert.equal(query.values[0], 'brian.m.carlson@gmail.com');
assert.equal(query.name, 'users');
});
test('provide an empty query name for toNamedQuery', function() {
var query = sql.select(user.id).from(user);
assert.throws(function() {
query.toNamedQuery('');
});
});
test('provide an undefined query name for toNamedQuery', function() {
var query = sql.select(user.id).from(user);
assert.throws(function() {
query.toNamedQuery();
});
});
test('override dialect for toNamedQuery using dialect name', function() {
var Sql = sql.Sql;
var mysql = new Sql('mysql');
var postgres = new Sql('postgres');
var sqlite = new Sql('sqlite');
var mssql = new Sql('mssql');
var oracle = new Sql('oracle');
var sqliteQuery = mysql.select(user.id).from(user).where(user.email.equals('brian.m.carlson@gmail.com')).toNamedQuery('user.select_brian','sqlite');
var postgresQuery = sqlite.select(user.id).from(user).where(user.email.equals('brian.m.carlson@gmail.com')).toNamedQuery('user.select_brian','postgres');
var mysqlQuery = postgres.select(user.id).from(user).where(user.email.equals('brian.m.carlson@gmail.com')).toNamedQuery('user.select_brian','mysql');
var oracleQuery = mssql.select(user.id).from(user).where(user.email.equals('brian.m.carlson@gmail.com')).toNamedQuery('user.select_brian','oracle');
var mssqlQuery = oracle.select(user.id).from(user).where(user.email.equals('brian.m.carlson@gmail.com')).toNamedQuery('user.select_brian','mssql');
var values = ['brian.m.carlson@gmail.com'];
assert.equal(sqliteQuery.text, 'SELECT "user"."id" FROM "user" WHERE ("user"."email" = $1)');
assert.deepEqual(sqliteQuery.values, values);
assert.equal('user.select_brian', sqliteQuery.name);
assert.equal(postgresQuery.text, 'SELECT "user"."id" FROM "user" WHERE ("user"."email" = $1)');
assert.deepEqual(postgresQuery.values, values);
assert.equal('user.select_brian', postgresQuery.name);
assert.equal(mysqlQuery.text, 'SELECT `user`.`id` FROM `user` WHERE (`user`.`email` = ?)');
assert.deepEqual(mysqlQuery.values, values);
assert.equal('user.select_brian', mysqlQuery.name);
assert.equal(mssqlQuery.text, 'SELECT [user].[id] FROM [user] WHERE ([user].[email] = @1)');
assert.deepEqual(mssqlQuery.values, values);
assert.equal('user.select_brian', mssqlQuery.name);
assert.equal(oracleQuery.text, 'SELECT "user"."id" FROM "user" WHERE ("user"."email" = :1)');
assert.deepEqual(oracleQuery.values, values);
assert.equal('user.select_brian', oracleQuery.name);
});
test('override dialect for toNamedQuery using invalid dialect name', function() {
var query = sql.select(user.id).from(user);
assert.throws(function() {
query.toNamedQuery('name', 'invalid');
});
});
test('mssql default parameter place holder is @index', function() {
var Sql = sql.Sql;
var mssql = new Sql('mssql');
var query = mssql.select(user.id).from(user).where(user.email.equals('x@y.com')).toQuery();
assert.equal(query.text, 'SELECT [user].[id] FROM [user] WHERE ([user].[email] = @1)');
assert.equal(query.values[0], 'x@y.com');
});
test('mssql override default parameter placeholder with ?', function() {
var Sql = sql.Sql;
var mssql = new Sql('mssql',{questionMarkParameterPlaceholder:true});
var query = mssql.select(user.id).from(user).where(user.email.equals('x@y.com')).toQuery();
assert.equal(query.text, 'SELECT [user].[id] FROM [user] WHERE ([user].[email] = ?)');
assert.equal(query.values[0], 'x@y.com');
});
});