nodejs-active-record-for-mysql

Динамическое создание запросов в базу данных MySQL для nodejs

Используется для динамичного формирования наиболее популярных запросов в БД MySQL
CREATE	- создание таблицы
DROP	- удаление таблицы
INSERT	- добавление записи
UPDATE	- обновление записей
DELETE	- удаление записей
SELECT	- получение записей

Пример подключения

var model_users = new (require('active-record-for-mysql'))({
	table 		: 'users';
	idkey 		: 'user_id';
	table_nick 	: 'Пользователи',
	engine		: 'InnoDB',
	charset		: 'utf8',
	fields 		: 
	[
		{
			field	: 'user_id', 
			label	: 'ID ПОЛЬЗОВАТЕЛЯ', 
			type	: 'int(11) NOT NULL',
			auto 	: 1,
		},
		{
			field	: 'user_name', 
			label	: 'ИМЯ ПОЛЬЗОВАТЕЛЯ', 
			type	: 'varchar(100) NOT NULL',
		},
		{
			field	: 'user_family', 
			label	: 'ФАМИЛМЯ ПОЛЬЗОВАТЕЛЯ', 
			type	: 'varchar(100) NOT NULL',
		},
		{
			field	: 'user_city_id', 
			label	: 'ID ГОРОДА ПОЛЬЗОВАТЕЛЯ', 
			type	: 'int(11) NOT NULL',
		}
	]
});

Примеры использования:

ЗАПРОС СОЗДАНИЯ ТАБЛИЦЫ

model_users.query_create();

CREATE TABLE IF NOT EXISTS `users` ( `user_id` int(11) NOT NULL AUTO_INCREMENT, `user_name` varchar(100) NOT NULL,`user_family` varchar(100) NOT NULL, `user_city_id` int(11) NOT NULL, PRIMARY KEY (`user_id`)) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;

ЗАПРОС УДАЛЕНИЯ ТАБЛИЦЫ

model_users.query_drop();

DROP TABLE IF EXISTS `users`;

ЗАПРОС ВСЕХ СТРОК СО ВСЕМИ ПОЛЯМИ

var data = {};
model_users.query_select(data);

SELECT * FROM users;

ЗАПРОС ВСЕХ СТРОК С ПЕРЕЧИСЛЕННЫМИ ПОЛЯМИ

var data = {
	fields : ['user_id', 'user_name', 'user_family']
};
model_users.query_select(data));

SELECT `user_id`, `user_name`, `user_family` FROM users;

ЗАПРОС ОДНОЙ СТРОКИ С ЗАДАННЫМ ID

var data = {
	fields 	: [],
	where 	: {
		user_id : 1,
	},
	limit 	: 1
};
model_users.query_select(data)

SELECT * FROM users WHERE `user_id`='1' LIMIT  1;

ЗАПРОС СТРОК НА УСЛОВИЯХ WHERE И IN

var data = {
	fields	: ['user_id', 'user_name', 'user_family'],
	where	: {
		user_family		: 'Иванов',
		'user_name !='		: 'Петр',
		'OR user_name !='	: 'Вася',
	},
	in		: {
		'user_id'		: [1,2,3],
		'user_profi'		: ['Сантехник', 'Электрик', 'Дворник']
	},
};
model_users.query_select(data)

SELECT `user_id`, `user_name`, `user_family` FROM users WHERE `user_family`='Иванов' AND `user_name`!='Петр' OR `user_name`!='Вася' AND `user_id` IN ('1', '2', '3') AND `user_profi` IN ('Сантехник', 'Электрик', 'Дворник');

ЗАПРОС СТРАНИЦЫ СТРОК СГРУППИРОВАННЫХ GROUP НА УСЛОВИЯХ LIKE С СОРТИРОВКОЙ

var data = {
	fields	: ['user_name', 'user_family'],
	group	: ['user_name', 'user_family'],
	like	: {
		user_family	: 'Ива',
		user_name	: 'etr%',
	},
	order	: {
		user_family	: 'asc',
		user_age	: 'desc'
	},
	limit	: 10,
	offset	: 5,
};
model_users.query_select(data));

SELECT `user_name`, `user_family` FROM users WHERE `user_family` LIKE '%Ива%' AND `user_name` LIKE 'etr%' GROUP BY user_name, user_family ORDER BY `user_family` ASC, `user_age` DESC LIMIT 5, 10;

ЗАПРОС ДОБАВЛЕНИЯ СТРОКИ

var data = {
	data	: {
		user_family	: 'Иванов',
		user_name	: 'Петр',
	}
};
model_users.query_insert(data));

INSERT INTO users SET `user_family`='Иванов', `user_name`='Петр';

ЗАПРОС ДОБАВЛЕНИЯ ДВОИЧНЫХ ДАННЫХ ИЗ ФАЙЛА (РЕДКО ИСПОЛЬЗУЕТСЯ)

var data = {
	data	: {
		user_family	: 'Иванов',
		user_name	: 'Петр',
		user_passport	: require('fs').readFileSync('./uploads/passport.jpg'),
	}
};
model_users.query_insert(data));

INSERT INTO users SET `user_family`='Иванов', `user_name`='Петр', ?;

ЗАПРОС ОБНОВЛЕНИЯ СТРОК НА УСЛОВИЯХ WHERE, IN, LIKE

var data = {
	data	: {
		user_family	: 'Иванов',
		user_name	: 'Петр',
	},
	where	: {
		user_family	: 'Петров',
		user_name	: 'Иван',
	},
	in	: {
		user_id		: [1,2,3],
	},
	like	: {
		user_family	: 'Ива',
		user_name	: 'etr%',
	},
};
model_users.query_update(data));

UPDATE users SET `user_family`='Иванов', `user_name`='Петр' WHERE `user_family`='Петров' AND `user_name`='Иван' AND `user_id` IN ('1', '2', '3') AND `user_family` LIKE '%Ива%' AND `user_name` LIKE 'etr%';

ЗАПРОС ОБНОВЛЕНИЯ ДВОИЧНЫХ ДАННЫХ ИЗ ФАЙЛА (РЕДКО ИСПОЛЬЗУЕТСЯ)

var data = {
	data	: {
		user_family	: 'Иванов',
		user_name	: 'Петр',
		user_passport	: require('fs').readFileSync('./uploads/passport.jpg'),
	},
	in	: {
		user_id		: [1,2,3],
	},
};
model_users.query_update(data));

UPDATE users SET `user_family`='Иванов', `user_name`='Петр', ? WHERE `user_id` IN ('1', '2', '3');

ЗАПРОС ОБНОВЛЕНИЯ ПОЛЯ В ЗАВИСИМОСТИ ОТ ЗНАЧЕНИЯ В ДРУГОМ ПОЛЕ (РЕДКО ИСПОЛЬЗУЕТСЯ)

var data = {
	data	: {
		user_profi	: {
			case		: {
				user_code	: {
					'A 01'		: 'Инженер-электрик',
					'B 11 3'	: 'Слесарь-сантехник 3 категории',
					'A 02'		: 'Инженер-конструктор',
					'С'		: 'Разнорабочий',
				},
			},
		}
	},
	in	: {
		user_id		: [1,2,3],
	},
};
model_users.query_update(data));

UPDATE users SET `user_profi` = CASE `user_code` WHEN 'A 01' THEN 'Инженер-электрик' WHEN 'B 11 3' THEN 'Слесарь-сантехник 3 категории' WHEN 'A 02' THEN 'Инженер-конструктор' WHEN 'С' THEN 'Разнорабочий' ELSE `user_profi` END WHERE `user_id` IN ('1', '2', '3');

ЗАПРОС УДАЛЕНИЯ СТРОК

var data = {
	where	: {
		user_family	: 'Иванов',
		'user_age >'	: 25
	}, 
	in	: {
		user_id		: [1,2,3]
	},
};
model_users.query_delete(data));

DELETE FROM users WHERE `user_family`='Иванов' AND `user_age`>'25' AND `user_id` IN ('1', '2', '3');

Тестирование

Пример серверного кода для проверки работоспособности расположен в директории "_demo"

Запуск тестов

node server

Результат

http://localhost:2020