Skip to content

public / sequelize

Go to a project

不要怂，就是干，撸起袖子干！

Commit 323c472d by Sascha Depold
Options

splitted parts into single files

1 parent a86e1308
Inline Side-by-side
Showing with 313 additions and 289 deletions
sequelize.js
...@@ -7,291 +7,4 @@ ...@@ -7,291 +7,4 @@
}) })
*/ */
require(__dirname + "/src/Sequelize")
exports.Sequelize = function(database, username, password) {
this.config = {
database: database,
username: username,
password: password
}
this.tables = {}
}
exports.Sequelize.STRING = 'VARCHAR(255)'
exports.Sequelize.TEXT = 'VARCHAR(4000)'
exports.Sequelize.INTEGER = 'INT'
exports.Sequelize.prototype = {
asTableName: function(name) {
return name + "s"
},
define: function(name, attributes) {
var table = new TableWrapper(this, this.asTableName(name), attributes)
table.attributes = attributes
this.tables[name] = {constructor: table, attributes: attributes}
table.sequelize = this
return table
},
get tableNames() {
var result = []
var self = this
Helper.Hash.keys(this.tables).forEach(function(tableName) {
result.push(self.asTableName(tableName))
})
return result
},
query: function(queryString, callback) {
var fields = []
var values = []
var self = this
var connection = require(__dirname+"/lib/nodejs-mysql-native/client").createTCPClient()
connection.auto_prepare = true
connection
.auth(this.config.database, this.config.username, this.config.password)
.addListener('authorized', function() {
Helper.log("Executing the query: " + queryString)
connection
.execute(queryString)
.addListener('row', function(r){ values.push(r) })
.addListener('field', function(f){ fields.push(f)})
.addListener('end', function() {
if(callback) {
var result = []
values.forEach(function(valueArray) {
var mapping = {}
for(var i = 0; i < fields.length; i++)
mapping[fields[i].name] = valueArray[i]
result.push(mapping)
})
callback(result)
}
})
connection.close()
})
}
}
// table object
var TableWrapper = function(sequelize, tableName, attributes) {
var table = function(values) {
var self = this
Helper.Hash.forEach(values, function(value, key) {
if(attributes[key])
self[key] = value
})
this.id = null // specify id as null to declare this object as unsaved and as not present in the database
this.tableName = tableName
this.attributes = attributes
}
// class methods
var classMethods = {
sync: function(callback) {
var fields = ["id INT NOT NULL auto_increment PRIMARY KEY"]
Helper.Hash.keys(attributes).forEach(function(name) { fields.push(name + " " + attributes[name]) })
var query = "CREATE TABLE IF NOT EXISTS " + tableName + " (" + fields.join(', ') + ")"
sequelize.query(query, function() {
if(callback) callback(table)
})
},
drop: function(callback) {
var query = "DROP TABLE IF EXISTS " + tableName
sequelize.query(query, function() {
if(callback) callback(table)
})
},
findAll: function(callback) {
var query = "SELECT * FROM " + tableName
sequelize.query(query, function(result) {
var objects = []
result.forEach(function(resultSet) {
objects.push(table.sqlResultToObject(resultSet))
})
if(callback) callback(objects)
})
},
find: function(conditions, callback) {
var query = Helper.evaluateTemplate(
"SELECT * FROM %{table} WHERE %{conditions} ORDER BY id DESC LIMIT 1",
{ table: tableName, conditions: Helper.SQL.hashToWhereConditions(conditions) }
)
sequelize.query(query, function(result) {
if (callback) callback(table.sqlResultToObject(result[0]))
})
},
sqlResultToObject: function(result) {
var object = new table(result)
object.id = result.id
return object
}
}
// instance methods
table.prototype = {
get values() {
var result = {}
var self = this
Helper.Hash.keys(attributes).forEach(function(attribute) {
result[attribute] = self[attribute]
})
return result
},
save: function(callback) {
var query = null
var self = this
if(this.id == null) {
query = Helper.evaluateTemplate(
"INSERT INTO %{table} (%{fields}) VALUES (%{values})",
{ table: this.tableName, fields: Helper.SQL.fieldsForInsertQuery(this), values: Helper.SQL.valuesForInsertQuery(this) }
)
} else {
query = Helper.evaluateTemplate(
"UPDATE %{table} SET %{values} WHERE id = %{id}",
{ table: this.tableName, values: Helper.SQL.valuesForUpdate(this), id: this.id }
)
}
sequelize.query(query, function() {
if(self.id == null) {
table.find(self.values, function(result) {
Helper.log(result)
self.id = result.id
if(callback) callback(self)
})
} else {
if(callback) callback(self)
}
})
},
updateAttributes: function(newValues, callback) {
var self = this
Helper.Hash.keys(this.attributes).forEach(function(attribute) {
if(newValues[attribute])
self[attribute] = newValues[attribute]
})
this.save(callback)
}
}
Helper.Hash.forEach(classMethods, function(func, funcName) {
table[funcName] = func
})
return table
}
// Helper methods
var Helper = {
log: function(obj) {
var sys = require("sys")
sys.puts(sys.inspect(obj))
},
SQL: {
valuesForInsertQuery: function(object) {
var actualValues = object.values,
result = []
Helper.Hash.keys(actualValues).forEach(function(key) {
var value = actualValues[key],
dataType = object.attributes[key]
result.push(Helper.SQL.transformValueByDataType(value, dataType))
})
return result
},
fieldsForInsertQuery: function(object) {
return Helper.Hash.keys(object.values).join(", ")
},
transformValueByDataType: function(value, dataType) {
var result = null
switch(dataType) {
case exports.Sequelize.INTEGER:
result = value; break;
default:
result = "'" + value + "'"; break;
}
return result
},
valuesForUpdate: function(object, options) {
var actualValues = object.values,
result = []
options = options || {}
Helper.Hash.keys(actualValues).forEach(function(key) {
var value = actualValues[key],
dataType = object.attributes[key]
result.push([key, Helper.SQL.transformValueByDataType(value, dataType)].join(" = "))
})
return result.join(options.seperator || ", ")
},
hashToWhereConditions: function(conditions) {
if(typeof conditions == 'number')
return ('id = ' + conditions)
else {
var result = []
Helper.Hash.forEach(conditions, function(value, key) {
result.push(key + "=" + Helper.SQL.transformValueByDataType(value))
})
return result.join(" AND ")
}
}
},
evaluateTemplate: function(template, replacements) {
var result = template
Helper.Hash.keys(replacements).forEach(function(key) {
result = result.replace("%{" + key + "}", replacements[key])
})
return result
},
Hash: {
forEach: function(object, func) {
Helper.Hash.keys(object).forEach(function(key) {
func(object[key], key, object)
})
},
keys: function(object) {
var results = []
for (var property in object)
results.push(property)
return results
},
values: function(object) {
var result = []
Helper.Hash.keys(object).forEach(function(key) {
result.push(object[key])
})
return result
}
}
}
exports.SequelizeHelper = Helper
\ No newline at end of file
src/Sequelize.js 0 → 100644
require(__dirname + "/SequelizeHelper")
require(__dirname + "/SequelizeTable")
Sequelize = function(database, username, password) {
this.config = {
database: database,
username: username,
password: password
}
this.tables = {}
}
var classMethods = {
STRING: 'VARCHAR(255)',
TEXT: 'VARCHAR(4000)',
INTEGER: 'INT',
sqlQueryFor: function(command, values) {
var query = null
switch(command) {
case 'create':
query = "CREATE TABLE IF NOT EXISTS %{table} (%{fields})"
break;
}
return SequelizeHelper.evaluateTemplate(query, values)
}
}
var instanceMethods = {
asTableName: function(name) {
return name + "s"
},
define: function(name, attributes) {
var table = new SequelizeTable(this, this.asTableName(name), attributes)
table.attributes = attributes
this.tables[name] = {constructor: table, attributes: attributes}
table.sequelize = this
return table
},
get tableNames() {
var result = []
var self = this
SequelizeHelper.Hash.keys(this.tables).forEach(function(tableName) {
result.push(self.asTableName(tableName))
})
return result
},
query: function(queryString, callback) {
var fields = []
var values = []
var self = this
var connection = require(__dirname+"/../lib/nodejs-mysql-native/client").createTCPClient()
connection.auto_prepare = true
connection
.auth(this.config.database, this.config.username, this.config.password)
.addListener('authorized', function() {
SequelizeHelper.log("Executing the query: " + queryString)
connection
.execute(queryString)
.addListener('row', function(r){ values.push(r) })
.addListener('field', function(f){ fields.push(f)})
.addListener('end', function() {
if(callback) {
var result = []
values.forEach(function(valueArray) {
var mapping = {}
for(var i = 0; i < fields.length; i++)
mapping[fields[i].name] = valueArray[i]
result.push(mapping)
})
callback(result)
}
})
connection.close()
})
}
}
SequelizeHelper.Hash.forEach(classMethods, function(method, methodName) {
Sequelize[methodName] = method
})
SequelizeHelper.Hash.forEach(instanceMethods, function(method, methodName) {
Sequelize.prototype[methodName] = method
})
\ No newline at end of file
src/SequelizeHelper.js 0 → 100644
SequelizeHelper = {
log: function(obj) {
var sys = require("sys")
sys.puts(sys.inspect(obj))
},
SQL: {
valuesForInsertQuery: function(object) {
var actualValues = object.values,
result = []
SequelizeHelper.Hash.keys(actualValues).forEach(function(key) {
var value = actualValues[key],
dataType = object.attributes[key]
result.push(SequelizeHelper.SQL.transformValueByDataType(value, dataType))
})
return result
},
fieldsForInsertQuery: function(object) {
return SequelizeHelper.Hash.keys(object.values).join(", ")
},
transformValueByDataType: function(value, dataType) {
SequelizeHelper.log(Sequelize)
var result = null
switch(dataType) {
case Sequelize.INTEGER:
result = value; break;
default:
result = "'" + value + "'"; break;
}
return result
},
valuesForUpdate: function(object, options) {
var actualValues = object.values,
result = []
options = options || {}
SequelizeHelper.Hash.keys(actualValues).forEach(function(key) {
var value = actualValues[key],
dataType = object.attributes[key]
result.push([key, SequelizeHelper.SQL.transformValueByDataType(value, dataType)].join(" = "))
})
return result.join(options.seperator || ", ")
},
hashToWhereConditions: function(conditions) {
if(typeof conditions == 'number')
return ('id = ' + conditions)
else {
var result = []
SequelizeHelper.Hash.forEach(conditions, function(value, key) {
result.push(key + "=" + SequelizeHelper.SQL.transformValueByDataType(value))
})
return result.join(" AND ")
}
}
},
evaluateTemplate: function(template, replacements) {
var result = template
SequelizeHelper.Hash.keys(replacements).forEach(function(key) {
result = result.replace("%{" + key + "}", replacements[key])
})
return result
},
Hash: {
forEach: function(object, func) {
SequelizeHelper.Hash.keys(object).forEach(function(key) {
func(object[key], key, object)
})
},
keys: function(object) {
var results = []
for (var property in object)
results.push(property)
return results
},
values: function(object) {
var result = []
SequelizeHelper.Hash.keys(object).forEach(function(key) {
result.push(object[key])
})
return result
}
}
}
\ No newline at end of file
src/SequelizeTable.js 0 → 100644
SequelizeTable = function(sequelize, tableName, attributes) {
var table = function(values) {
var self = this
SequelizeHelper.Hash.forEach(values, function(value, key) {
if(attributes[key])
self[key] = value
})
this.id = null // specify id as null to declare this object as unsaved and as not present in the database
this.tableName = tableName
this.attributes = attributes
}
// class methods
var classMethods = {
sync: function(callback) {
var fields = ["id INT NOT NULL auto_increment PRIMARY KEY"]
SequelizeHelper.Hash.keys(attributes).forEach(function(name) { fields.push(name + " " + attributes[name]) })
var query = "CREATE TABLE IF NOT EXISTS " + tableName + " (" + fields.join(', ') + ")"
sequelize.query(query, function() {
if(callback) callback(table)
})
},
drop: function(callback) {
var query = "DROP TABLE IF EXISTS " + tableName
sequelize.query(query, function() {
if(callback) callback(table)
})
},
findAll: function(callback) {
var query = "SELECT * FROM " + tableName
sequelize.query(query, function(result) {
var objects = []
result.forEach(function(resultSet) {
objects.push(table.sqlResultToObject(resultSet))
})
if(callback) callback(objects)
})
},
find: function(conditions, callback) {
var query = SequelizeHelper.evaluateTemplate(
"SELECT * FROM %{table} WHERE %{conditions} ORDER BY id DESC LIMIT 1",
{ table: tableName, conditions: SequelizeHelper.SQL.hashToWhereConditions(conditions) }
)
sequelize.query(query, function(result) {
if (callback) callback(table.sqlResultToObject(result[0]))
})
},
sqlResultToObject: function(result) {
var object = new table(result)
object.id = result.id
return object
}
}
// instance methods
var instanceMethods = {
get values() {
var result = {}
var self = this
SequelizeHelper.Hash.keys(attributes).forEach(function(attribute) {
result[attribute] = self[attribute]
})
return result
},
save: function(callback) {
var query = null
var self = this
if(this.id == null) {
query = SequelizeHelper.evaluateTemplate(
"INSERT INTO %{table} (%{fields}) VALUES (%{values})",
{ table: this.tableName, fields: SequelizeHelper.SQL.fieldsForInsertQuery(this), values: SequelizeHelper.SQL.valuesForInsertQuery(this) }
)
} else {
query = SequelizeHelper.evaluateTemplate(
"UPDATE %{table} SET %{values} WHERE id = %{id}",
{ table: this.tableName, values: SequelizeHelper.SQL.valuesForUpdate(this), id: this.id }
)
}
sequelize.query(query, function() {
if(self.id == null) {
table.find(self.values, function(result) {
SequelizeHelper.log(result)
self.id = result.id
if(callback) callback(self)
})
} else {
if(callback) callback(self)
}
})
},
updateAttributes: function(newValues, callback) {
var self = this
SequelizeHelper.Hash.keys(this.attributes).forEach(function(attribute) {
if(newValues[attribute])
self[attribute] = newValues[attribute]
})
this.save(callback)
},
destroy: function(callback) {
}
}
SequelizeHelper.Hash.forEach(classMethods, function(method, methodName) {
table[methodName] = method
})
SequelizeHelper.Hash.forEach(instanceMethods, function(method, methodName) {
table.prototype[methodName] = method
})
return table
}
\ No newline at end of file
Markdown is supported
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!