How to use knex

database.js

GitHub: jolimaj17/tri-sakay-backend

10
11
12
13
14
15
16
17
18
19
20
21
    console.error("Can't connect to DB!")
    throw error
  })


if (process.env.NODE_ENV !== 'production') {
  knex.on('error', (error) => {
    console.log('Error', error)
  })


  knex.on('query', (query) => {

0

0

0

See more examples

index.js

GitHub: ericadamski/knex-case

-4

1

1

1

See more examples

index.js

GitHub: GromovoiStanislav/KnexJS_ORM

34
35
36
37
38
39
40
41
42
43

//const data = await knex.select('id as identifier').from('users');
//const data = await knex.select(knex.ref('id').as('identifier')).from('users');

// const data = await knex
//   .select(knex.ref('id'), knex.ref('login'))
//   .from('users');
// const data = await knex
//   .select(knex.ref('id').as('identifier'))
//   .select(knex.ref('login').as('name'))

0

0

1

See more examples

index.js

GitHub: GromovoiStanislav/KnexJS_ORM

44
45
46
47
48
49
50
51
52
53
//   .from('users');

//const data = await knex.sum('age').from('users2');
//const data = await knex.avg('age').from('users2');
//const data = await knex.max('age').from('users2');
//const data = await knex.min('age').from('users2');

// const data = await knex.avg('sum_age').from(function () {
//   this.sum('age as sum_age').from('users2').groupBy('name').as('t1');
// });

0

0

1

See more examples

index.js

GitHub: GromovoiStanislav/KnexJS_ORM

43
44
45
46
47
48
49
50
51
52
//   .select(knex.ref('login').as('name'))
//   .from('users');

//const data = await knex.sum('age').from('users2');
//const data = await knex.avg('age').from('users2');
//const data = await knex.max('age').from('users2');
//const data = await knex.min('age').from('users2');

// const data = await knex.avg('sum_age').from(function () {
//   this.sum('age as sum_age').from('users2').groupBy('name').as('t1');

0

0

1

See more examples

index.js

GitHub: GromovoiStanislav/KnexJS_ORM

41
42
43
44
45
46
47
48
49
// const data = await knex
//   .select(knex.ref('id').as('identifier'))
//   .select(knex.ref('login').as('name'))
//   .from('users');

//const data = await knex.sum('age').from('users2');
//const data = await knex.avg('age').from('users2');
//const data = await knex.max('age').from('users2');
//const data = await knex.min('age').from('users2');

0

0

1

See more examples

index.js

GitHub: ninja0911/nodejs-framework-sotatek

48
49
50
51
52
53
54
55
56
57
58
requireDir('core', { recurse: true });
requireDir('usercases', { recurse: true });


function cleanDBAndFlushCache(done) {
  logger.info('Cleaning the test DB after each test...');
  knex.seed.run()
    .then(function () {
      client.flushdb(done);
    })
    .catch(function(err) {

0

1

0

See more examples

index.js

GitHub: GromovoiStanislav/KnexJS_ORM

67
68
69
70
71
72
73
74
75

// const subquery = knex.select('name', 'age').from('users2').as('u');
// const data = await knex.select('u.name', 'u.age').from(subquery);

//const data = await knex.column('id', 'name', 'age').select().from('users2');
//const data = await knex.column(['id', 'name', 'age']).from('users2');
// const data = await knex
//   .column('id as identifier', { by: 'name' }, 'age')
//   .from('users2');

0

0

1

See more examples

README.md?plain=1

GitHub: aldy505/winston-knex

61
62
63
64
65
66
67
68
69
70
```js
const knex = require('knex')({ ...config })

async function getLogsValue() {
  try {
    const trxProvider = knex.transactionProvider();
    const trx = await trxProvider();
    const logs = await trx('tableName').select();
    return logs;
  } catch (error) {

0

1

0

See more examples

Query%20Builder%20(%20Knex.js).md?plain=1

GitHub: im-d-team/Dev-Docs

8
9
10
11
12
13
14
15
16
17
Knex.js는 다양한 DBMS(**Postgres, MSSQL, MySQL, MariaDB, SQLite3, Oracle, and Amazon Redshift**)를 지원하고 있고 단순 Query 생성 뿐만 아니라 **schema builder, transaction, connection pooling** 등의 기능도 지원하고 있다. 자세한 내용은 [공식홈페이지](http://knexjs.org)를 살펴보자.

우선 프로젝트에 `npm install knex —save` 로 knex 모듈을 추가하고 다음과 같이 DB에 연결한다. 

```jsx
// knex.js

const knex = require('knex')({
    client: 'mysql2',
    connection: {

21

144

4

See more examples

media-controller.js

GitHub: mirfishe/PKD-and-Me-Server-V2

198
199
200
201
202
203
204
205
206
207
// const createMedia = {
//     media:      request.body.recordObject.media,
//     sortID:     newSortID
//   };

db.queryBuilder()
  .from(tableName)
  .max("sortID")
  .first() // * Add this to get an object. -- 05/06/2021 MF
  .then((maxSortID) => {

0

0

0

See more examples

index.js

GitHub: GromovoiStanislav/KnexJS_ORM

42
43
44
45
46
47
48
49
50
51
//   .select(knex.ref('id').as('identifier'))
//   .select(knex.ref('login').as('name'))
//   .from('users');

//const data = await knex.sum('age').from('users2');
//const data = await knex.avg('age').from('users2');
//const data = await knex.max('age').from('users2');
//const data = await knex.min('age').from('users2');

// const data = await knex.avg('sum_age').from(function () {

0

0

1

See more examples

index.js

GitHub: ninja0911/nodejs-framework-sotatek

27
28
29
30
31
32
33
34
35
36
before(function(done) {
  logger.fatal('Setting up the test DB before running tests...');
  knex.migrate.rollback()
    .then(function() {
      logger.fatal('Migrate latest DB schema...');
      return knex.migrate.latest();
    })
    .then(function () {
      logger.fatal('Creating DB seeds...');
      return knex.seed.run();

0

1

0

See more examples

adapter-knex.js

GitHub: keystonejs/keystone-5

30
31
32
33
34
35
36
37
38
39
  connection || process.env.CONNECT_TO || process.env.DATABASE_URL || process.env.KNEX_URI;

if (!knexConnection) {
  throw new Error(`No Knex connection URI specified.`);
}
this.knex = knex({
  client: this.client,
  connection: knexConnection,
  ...knexOptions,
});

31

62

17

See more examples

index.js

GitHub: GromovoiStanislav/KnexJS_ORM

800
801
802
803
804
805
806
807
808
809
// //select * from "users" inner join "accounts" on "accounts"."type" = "admin"

//const data = await knex.from('users').innerJoin('accounts','users.id','accounts.user_id');
//select * from "users" inner join "accounts" on "users"."id" = "accounts"."user_id"

// const data = await knex.table('users').innerJoin('accounts', 'users.id', '=', 'accounts.user_id');
// //select * from "users" inner join "accounts" on "users"."id" = "accounts"."user_id"

// const data = await knex('users').innerJoin('accounts',  (qb) => {
//   qb.on('accounts.id', '=', 'users.account_id')

0

0

1

See more examples

knex-database-connection.js

GitHub: 1024pix/pix

30
31
32
33
34
35
36
37
38
39
/* QueryBuilder Extension */
const Knex = require('knex');
const QueryBuilder = require('knex/lib/query/querybuilder');

try {
  Knex.QueryBuilder.extend('whereInArray', function (column, values) {
    return this.where(column, knex.raw('any(?)', [values]));
  });
} catch (e) {
  if (e.message !== "Can't extend QueryBuilder with existing method ('whereInArray').") {

49

199

22

See more examples

cinemasRoutes.js

GitHub: ManuBansalProjects/cinema-fullstack-backend

97
98
99
100
101
102
103
104
105
106
107


//getting cinemaid by cinema name
router.get('/getcinemaidbyname/:cinemaname', async (req, res) => {
  try {
    console.log('sending cinema id by cinema name');
    const result = await knex.withSchema('bookmyshow').table('cinemas').where('name', req.params.cinemaname);
    res.json({ result: result[0].id });
  }
  catch (error) {
    console.log(error);

0

0

0

See more examples

database.js

GitHub: Ocelotworks/OcelotBOTv5

95
96
97
98
99
100
101
102
103
104
 * This generally shouldn't be used in favour of `bot.database.leaveServer`
 * @param {ServerID} serverID The server's Snowflake ID
 * @returns {Promise<Array>}
 */
deleteServer: function deleteServer(serverID) {
    return knex.delete()
        .from(SERVERS_TABLE)
        .where({
            server: serverID
        });

7

35

0

See more examples

knex_trx.js

GitHub: ais-one/cookbook

29
30
31
32
33
34
35
36
37
38
await knex('test_table').truncate()

console.log('See Transaction...')
await knex.transaction(async trx => {  
  await knex('test_table').insert({ name: 'aa' }).transacting(trx)
  // await knex.schema.raw('SET TRANSACTION ISOLATION LEVEL READ UNCOMMITTED;')
  let rv = await knex.select().from('test_table')
  console.log(rv)

  await knex('test_table').insert({ name: 'bb' }).transacting(trx)

116

447

29

See more examples

knex_trx.js

GitHub: ais-one/cookbook

27
28
29
30
31
32
33
34
35
36

// empty data
await knex('test_table').truncate()

console.log('See Transaction...')
await knex.transaction(async trx => {  
  await knex('test_table').insert({ name: 'aa' }).transacting(trx)
  // await knex.schema.raw('SET TRANSACTION ISOLATION LEVEL READ UNCOMMITTED;')
  let rv = await knex.select().from('test_table')
  console.log(rv)

116

447

29

See more examples

database.js

GitHub: Ocelotworks/OcelotBOTv5

77
78
79
80
81
82
83
84
85
86
 * @param webhookID
 * @param webhookToken
 * @returns {Promise<Array>}
 */
addServer: function addNewServer(server, addedBy, name, timestamp, language = "en-gb", webhookID, webhookToken) {
    return knex.insert({
        server,
        owner: addedBy,
        name,
        prefix: "!",

7

35

0

See more examples

index.js

GitHub: GromovoiStanislav/KnexJS_ORM

76
77
78
79
80
81
82
83
84
85
86
87
88


  const data = await knex.select().from('users2').offset(1).limit(2);
  //.toSQL().sql;


  console.log(data);
  knex.destroy();
}


async function createTable() {
  // await knex.schema.createTable('users2', (table) => {

0

0

1

See more examples

database.js

GitHub: Ocelotworks/OcelotBOTv5

82
83
84
85
86
87
88
89
90
91
return knex.insert({
    server,
    owner: addedBy,
    name,
    prefix: "!",
    timestamp: knex.raw(`FROM_UNIXTIME(${(timestamp ? new Date(timestamp).getTime() : new Date().getTime()) / 1000})`),
    language,
    webhookID,
    webhookToken
}).into(SERVERS_TABLE);

7

35

0

See more examples

knex_trx.js

GitHub: ais-one/cookbook

30
31
32
33
34
35
36
37
38
39

console.log('See Transaction...')
await knex.transaction(async trx => {  
  await knex('test_table').insert({ name: 'aa' }).transacting(trx)
  // await knex.schema.raw('SET TRANSACTION ISOLATION LEVEL READ UNCOMMITTED;')
  let rv = await knex.select().from('test_table')
  console.log(rv)

  await knex('test_table').insert({ name: 'bb' }).transacting(trx)
  await knex.schema.raw('SET TRANSACTION ISOLATION LEVEL READ UNCOMMITTED;')

116

447

29

See more examples

urls.model.js

GitHub: Hakobyan001/Links_Guardian_Cluster

34
35
36
37
38
39
40
41
42
  }
}

static async getUrls() {

  const selectNullableData = await knex.from('urls').select('external_urls',).where('robot_tag', null)
    .orderBy('id');

  return selectNullableData;

0

0

1

See more examples