Как создать команду для sql?

Question

[gifon]

Здравствуйте, у меня есть обэкт

let obj={
id:1,
name: "someName",
lastName: "someLastName",
}

И я хочу залить в базу все его поля
база типа

CREATE TABLE myTable (id BIGINT NOT NULL PRIMARY KEY, firstName VARCHAR(50) UNIQUE, lastName VARCHAR(50));

Чтоб создать команду sql
пришлось наделать такое

let query = "";
          query += "INSERT INTO";
          query += " " + obj.__TABLE_NAME;
          query += "(";
          for (field in obj) {
            query += field + ",";
          }
          query += ") " + "VALUES" + " (";
          for (field in obj) {
            query += obj[field] + ",";
          }
          query += ")";
          query += "ON CONFLICT (name)";
          query += "DO UPDATE SET ";
          for (field in obj) {
            query += field + " = " + "EXCLUDED." + field + " ";
          }
          query = ";";

Но почему-то мне это напоминает г-код, существуют ли другие подходы...

Comments

[FanatPHP]

это не просто говнокод, это говнокод в квадрате. гальюн с дырками в полу на 20 персон.
и после него тут же полезут ошибки и уязвимости
другие подходы можно посмотреть в любом, совершенно любом учебнике.
или даже среди вопросов на этом сайте. если потужиться и постараться вспомнить название языка, на котором пишешь.

[Сергей Горностаев]

Во-первых, судя по конктексту, вопрос должен звучать "как генерировать sql-запрос". Во-вторых, зачем изобретать велосипед, если для JS есть как минимум десяток готовых ORM?

[Дмитрий]

Сергей Горностаев, десяток?

[freeExec]

FanatPHP, Гальюн на 20 персон, это если данные у тебя от пользователей. А если тебе один раз надо импортировать 200М записей в базу, то чистый SQL-код на порядок быстрее, че все эти новомодные биндинги.

[FanatPHP]

freeExec, гальюн на 20 персон у вас в голове. В вашем коротком комментарии примерно столько ошибок и глупостей.
Откуда вы здесь взяли "200М записей"? Обсуждаемый вопрос вообще не про это.
Даже если импортировать, то откуда возьмутся эти 200М? искусственный интеллект нагенерил? Нет, разумеется - те же хомячки и понаписали.
Поэтому "биндинги" надо использовать всегда, для любых операций с базой данных. или нарваться на инъекцию второго порядка
Главное, какие угодно "пользователи" здесь в любом случае не при делах. Управляющие команды SQL, которые тупо случайно поломают запрос, могут оказаться в любых данных, независимо от источника.
"Использование биндингов" - это аксиома для всего мира уже много лет, спорить с этим - это заведомо выставлять себя дураком
На порядок быстрее - это какая-то совсем глупость. откуда здесь возьмется этот "порядок"? "биндинги" будут как раз быстрее, только не на "порядок", а процентов на 5. Потому что они так работают. Рекомендую учить матчасть перед тем как выступать с такими заявлениями.

Answer 1

[romaro]

Можно создать в базе функцию, которая принимает json:

CREATE TABLE my_table (id BIGINT NOT NULL PRIMARY KEY, first_name VARCHAR(50) UNIQUE, last_name VARCHAR(50));

CREATE FUNCTION add_obj (p_obj json)
RETURNS int
LANGUAGE plpgsql
AS $$
DECLARE
	p_id int := p_obj ->> 'id';
	p_name TEXT := p_obj ->> 'name';
	p_last_name TEXT := p_obj ->> 'lastName';
BEGIN 
	INSERT INTO my_table (
		id, first_name, last_name
	) VALUES (
		p_id, p_name, p_last_name
	) RETURNING id;
END;
$$;

Затем взять низкоуровневую библиотеку:
npm i pg

И с ее помощью дергать функцию:

import pkg from 'pg';
const { Pool } = pkg;

export class PostgresDriver {
	constructor(config) {
		this.pool = new Pool(config);
		this.pool.on('error', err => {
			console.error('StoreDB Postgres error', err);
		});
	}

	async getPoolClient() {
		try {
			return await this.pool.connect();
		} catch (e) {
			throw new Error('StoreDB -> poolConnect() ->', e.message);
		}
	}

	async addObject(obj) {
		const json = JSON.stringify(obj);
		const sql = `CALL add_obj('${json}');`;
		try {
			const client = await this.getPoolClient();
			const rs = await client.query(sql);
			client.release();
			return rs;
		} catch (e) {
			throw new Error(`PostgresDriver -> ${sql}`);
		}
	}
}

Но я бы рекомендовал переименовать id в ext_id и добавить к таблице безопасный первичный ключ с типом serial.