@@ -11,7 +11,7 @@ if (local) {
11
11
user : "root" ,
12
12
password : "root" ,
13
13
database : "crawl" ,
14
- multipleStatements : true //是否允许执行多条sql语句
14
+ multipleStatements : true , //是否允许执行多条sql语句
15
15
} ) ;
16
16
} else {
17
17
pool = mysql . createPool ( {
@@ -20,19 +20,19 @@ if (local) {
20
20
user : "root" ,
21
21
password : "websoft9" ,
22
22
database : "motion" ,
23
- multipleStatements : true //是否允许执行多条sql语句
23
+ multipleStatements : true , //是否允许执行多条sql语句
24
24
} ) ;
25
25
}
26
26
27
27
//将结果已对象数组返回
28
28
var row = ( sql , ...params ) => {
29
- return new Promise ( function ( resolve , reject ) {
30
- pool . getConnection ( function ( err , connection ) {
29
+ return new Promise ( function ( resolve , reject ) {
30
+ pool . getConnection ( function ( err , connection ) {
31
31
if ( err ) {
32
32
reject ( err ) ;
33
33
return ;
34
34
}
35
- connection . query ( sql , params , function ( error , res ) {
35
+ connection . query ( sql , params , function ( error , res ) {
36
36
connection . release ( ) ;
37
37
if ( error ) {
38
38
reject ( error ) ;
@@ -46,13 +46,13 @@ var row = (sql, ...params) => {
46
46
47
47
//返回一个对象
48
48
var first = ( sql , ...params ) => {
49
- return new Promise ( function ( resolve , reject ) {
50
- pool . getConnection ( function ( err , connection ) {
49
+ return new Promise ( function ( resolve , reject ) {
50
+ pool . getConnection ( function ( err , connection ) {
51
51
if ( err ) {
52
52
reject ( err ) ;
53
53
return ;
54
54
}
55
- connection . query ( sql , params , function ( error , res ) {
55
+ connection . query ( sql , params , function ( error , res ) {
56
56
connection . release ( ) ;
57
57
if ( error ) {
58
58
reject ( error ) ;
@@ -66,13 +66,13 @@ var first = (sql, ...params) => {
66
66
67
67
//返回单个查询结果
68
68
var single = ( sql , ...params ) => {
69
- return new Promise ( function ( resolve , reject ) {
70
- pool . getConnection ( function ( err , connection ) {
69
+ return new Promise ( function ( resolve , reject ) {
70
+ pool . getConnection ( function ( err , connection ) {
71
71
if ( err ) {
72
72
reject ( err ) ;
73
73
return ;
74
74
}
75
- connection . query ( sql , params , function ( error , res ) {
75
+ connection . query ( sql , params , function ( error , res ) {
76
76
connection . release ( ) ;
77
77
if ( error ) {
78
78
reject ( error ) ;
@@ -90,15 +90,15 @@ var single = (sql, ...params) => {
90
90
91
91
//执行代码,返回执行结果
92
92
var execute = ( sql , ...params ) => {
93
- return new Promise ( function ( resolve , reject ) {
93
+ return new Promise ( function ( resolve , reject ) {
94
94
// 获取连接
95
- pool . getConnection ( function ( err , connection ) {
95
+ pool . getConnection ( function ( err , connection ) {
96
96
if ( err ) {
97
97
reject ( err ) ;
98
98
return ;
99
99
}
100
100
// 操作数据库
101
- connection . query ( sql , params , function ( error , res ) {
101
+ connection . query ( sql , params , function ( error , res ) {
102
102
// 释放
103
103
connection . release ( ) ;
104
104
if ( error ) {
@@ -116,7 +116,7 @@ module.exports = {
116
116
ROW : row ,
117
117
FIRST : first ,
118
118
SINGLE : single ,
119
- EXECUTE : execute
119
+ EXECUTE : execute ,
120
120
} ;
121
121
122
122
/*连接mysql*/
@@ -125,11 +125,11 @@ function connectToMysql() {
125
125
host : "182.254.153.189" ,
126
126
user : "root" ,
127
127
password : "websoft9" ,
128
- database : "motion"
128
+ database : "motion" ,
129
129
} ) ;
130
130
connection . connect ( ) ;
131
131
//查询
132
- connection . query ( "SELECT * FROM user;" , function ( err , rows , fields ) {
132
+ connection . query ( "SELECT * FROM user;" , function ( err , rows , fields ) {
133
133
if ( err ) throw err ;
134
134
console . log ( "The solution is: " , rows [ 0 ] ) ;
135
135
} ) ;
0 commit comments