jeefo-mysql
Advanced tools
Comparing version 0.0.11 to 0.0.12
{ | ||
"name": "jeefo-mysql", | ||
"version": "0.0.11", | ||
"version": "0.0.12", | ||
"description": "Very simple MySQL connection instances for each table. I had annoyed enough for MySQL Deadlocks.", | ||
@@ -5,0 +5,0 @@ "main": "index.js", |
/* -.-.-.-.-.-.-.-.-.-.-.-.-.-.-.-.-.-.-.-. | ||
* File Name : prepare_insert.js | ||
* Created at : 2016-09-28 | ||
* Updated at : 2016-09-29 | ||
* Updated at : 2016-10-02 | ||
* Author : jeefo | ||
@@ -19,14 +19,9 @@ * Purpose : | ||
let sprintf = require("jeefo").sprintf, | ||
get_placeholders = require("./placeholders"), | ||
escape_identifier = require("mysql").escapeId; | ||
module.exports = (table, data, return_back) => { | ||
let fields = [], values = []; | ||
let values_placeholders = Object.keys(data).reduce((result, key) => { | ||
fields.push(key); | ||
values.push(data[key]); | ||
return result + '?, '; | ||
}, ''); | ||
fields.push("created_at", "updated_at"); | ||
let values = []; | ||
let fields = get_placeholders(data, values); | ||
fields += "`created_at` = NOW(), `updated_at` = NOW()"; | ||
table = escape_identifier(table); | ||
@@ -38,7 +33,3 @@ | ||
} | ||
query += sprintf(" INSERT INTO { table }({ fields }) VALUES({ values_placeholders }NOW(), NOW());", { | ||
table, | ||
fields : escape_identifier(fields), | ||
values_placeholders, | ||
}); | ||
query += sprintf(" INSERT INTO { table } SET { fields };", { table, fields }); | ||
if (return_back) { | ||
@@ -45,0 +36,0 @@ query += sprintf(" SELECT * FROM { 0 } ORDER BY `id` DESC LIMIT 1; COMMIT;", table); |
/* -.-.-.-.-.-.-.-.-.-.-.-.-.-.-.-.-.-.-.-. | ||
* File Name : prepare_update.js | ||
* Created at : 2016-09-27 | ||
* Updated at : 2016-10-01 | ||
* Updated at : 2016-10-02 | ||
* Author : jeefo | ||
@@ -19,22 +19,9 @@ * Purpose : | ||
let jeefo = require("jeefo"), | ||
map = jeefo.map, | ||
$where = require("./where"), | ||
is_null = jeefo.is_null, | ||
sprintf = jeefo.sprintf, | ||
prepare_select = require("./prepare_select"), | ||
get_placeholders = require("./placeholders"), | ||
escape_identifier = require("mysql").escapeId; | ||
let get_placeholders = (object, values) => { | ||
return Object.keys(object).reduce((result, key) => { | ||
let value = object[key]; | ||
key = "`0`".replace(0, key); | ||
if (is_null(value)) { | ||
return `${ result }${ key } = NULL, `; | ||
} | ||
values.push(value); | ||
return `${ result }${ key }= ?, `; | ||
}, ''); | ||
}; | ||
module.exports = (table, data, where, return_back) => { | ||
@@ -57,3 +44,3 @@ let values = []; | ||
$select.push("updated_at"); | ||
let copy_where = jeefo.map(where, { $select }); | ||
let copy_where = map(where, { $select }); | ||
@@ -60,0 +47,0 @@ let select = prepare_select(table, copy_where); |
20935
13
694