@@ -84,27 +84,27 @@ const port = 3000;
84
84
const client = new Client (' postgres://postgres:postgres@localhost:5432/postgres' );
85
85
86
86
app .post (' /query' , async (req , res ) => {
87
- const { sql, params, method } = req .body ;
87
+ const { sql, params, method } = req .body ;
88
88
89
- // prevent multiple queries
90
- const sqlBody = sql .replace (/ ;/ g , ' ' );
89
+ // prevent multiple queries
90
+ const sqlBody = sql .replace (/ ;/ g , ' ' );
91
91
92
- try {
93
- const result = await client .query ({
94
- text: sqlBody ,
95
- values: params ,
96
- rowMode: method === ' all' ? ' array' : undefined ,
97
- });
98
- res .send (result .rows );
99
- } catch (e : any ) {
100
- res .status (500 ).json ({ error: e });
101
- }
102
-
103
- res .status (500 ).json ({ error: ' Unknown method value' });
92
+ try {
93
+ const result = await client .query ({
94
+ text: sqlBody ,
95
+ values: params ,
96
+ rowMode: method === ' all' ? ' array' : undefined ,
97
+ });
98
+ res .send (result .rows );
99
+ } catch (e : any ) {
100
+ res .status (500 ).json ({ error: e });
101
+ }
102
+
103
+ res .status (500 ).json ({ error: ' Unknown method value' });
104
104
});
105
105
106
106
app .listen (port , () => {
107
- console .log (` Example app listening on port ${port } ` );
107
+ console .log (` Example app listening on port ${port } ` );
108
108
});
109
109
```
110
110
</Section >
@@ -138,10 +138,10 @@ const main = async () => {
138
138
const connection
= await mysql .
createConnection (
' mysql://root:[email protected] :5432/drizzle' );
139
139
140
140
app .post (' /query' , async (req , res ) => {
141
- const { sql, params, method } = req .body ;
141
+ const { sql, params, method } = req .body ;
142
142
143
143
// prevent multiple queries
144
- const sqlBody = sql .replace (/ ;/ g , ' ' );
144
+ const sqlBody = sql .replace (/ ;/ g , ' ' );
145
145
146
146
try {
147
147
const result = await connection .query ({
@@ -155,20 +155,20 @@ const main = async () => {
155
155
return next ();
156
156
},
157
157
});
158
- } catch (e : any ) {
159
- res .status (500 ).json ({ error: e });
160
- }
161
-
162
- if (method === ' all' ) {
163
- res .send (result [0 ]);
164
- } else if (method === ' execute' ) {
165
- res .send (result );
166
- }
167
- res .status (500 ).json ({ error: ' Unknown method value' });
158
+ } catch (e : any ) {
159
+ res .status (500 ).json ({ error: e });
160
+ }
161
+
162
+ if (method === ' all' ) {
163
+ res .send (result [0 ]);
164
+ } else if (method === ' execute' ) {
165
+ res .send (result );
166
+ }
167
+ res .status (500 ).json ({ error: ' Unknown method value' });
168
168
});
169
169
170
170
app .listen (port , () => {
171
- console .log (` Example app listening on port ${port } ` );
171
+ console .log (` Example app listening on port ${port } ` );
172
172
});
173
173
}
174
174
@@ -205,15 +205,15 @@ type ResponseType = { rows: any[][] | any[] }[];
205
205
const db = drizzle (async (sql , params , method ) => {
206
206
// single queries logic. Same as in code above
207
207
}, async (queries : { sql: string , params: any [], method: ' all' | ' run' | ' get' | ' values' }[]) => {
208
- try {
209
- const result: ResponseType = await axios .post (' http://localhost:3000/batch' , { queries });
210
-
211
- return result ;
212
- } catch (e : any ) {
213
- console .error (' Error from sqlite proxy server:' , e );
214
- throw e ;
215
- }
216
- });
208
+ try {
209
+ const result: ResponseType = await axios .post (' http://localhost:3000/batch' , { queries });
210
+
211
+ return result ;
212
+ } catch (e : any ) {
213
+ console .error (' Error from sqlite proxy server:' , e );
214
+ throw e ;
215
+ }
216
+ });
217
217
```
218
218
219
219
And then you can use ` db.batch([]) ` method, that will proxy all queries
0 commit comments