forked from shikshalokam/sl-dhiti-service
-
Notifications
You must be signed in to change notification settings - Fork 0
/
db.js
99 lines (85 loc) · 2.77 KB
/
db.js
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
// var ExpressCassandra = require('express-cassandra');
// var config = require('./config/config')
// var models = ExpressCassandra.createClient({
// clientOptions: {
// contactPoints: [config.cassandra.host],
// protocolOptions: { port: config.cassandra.port },
// keyspace: config.cassandra.keyspace,
// queryOptions: {consistency: ExpressCassandra.consistencies.one}
// },
// ormOptions: {
// defaultReplicationStrategy : {
// class: 'SimpleStrategy',
// replication_factor: 1
// },
// migration: 'safe',
// }
// });
// var MyModel = models.loadSchema(config.cassandra.table, {
// fields:{
// id : "uuid",
// qid : "text",
// query : "text"
// },
// key:["id"]
// });
// var reportIndexes = models.loadSchema(config.cassandra.apiReqAndResTable, {
// fields:{
// id : {
// type: "uuid",
// default: {"$db_function": "uuid()"}
// },
// apirequest : 'text',
// apiresponse : 'text',
// downloadpdfpath : 'text'
// },
// key:['id']
// });
// var assessmentModel = models.loadSchema(config.cassandra.assessmentTable, {
// fields:{
// id : {
// type: "uuid",
// default: {"$db_function": "uuid()"}
// },
// apirequest : 'text',
// apiresponse : 'text',
// downloadpdfpath : 'text'
// },
// key:['id']
// });
// // var migrationModel = models.loadSchema(config.cassandra.migrationTable, {
// // fields:{
// // id : {
// // type: "uuid",
// // default: {"$db_function": "uuid()"}
// // },
// // filename : 'text',
// // appliedat : 'timestamp',
// // message : 'text'
// // },
// // key:['id']
// // });
// // MyModel or models.instance.Person can now be used as the model instance
// // sync the schema definition with the cassandra database table
// // if the schema has not changed, the callback will fire immediately
// // otherwise express-cassandra will try to migrate the schema and fire the callback afterwards
// MyModel.syncDB(function(err, result) {
// if (err) throw err;
// // result == true if any database schema was updated
// // result == false if no schema change was detected in your models
// });
// reportIndexes.syncDB(function(err, result) {
// if (err) throw err;
// });
// assessmentModel.syncDB(function(err, result) {
// if (err) throw err;
// });
// // migrationModel.syncDB(function(err, result) {
// // if (err) throw err;
// // });
// module.exports = {
// MyModel : MyModel,
// reportIndexes : reportIndexes,
// assessmentModel : assessmentModel
// // migrationModel : migrationModel
// }