You've already forked OpenIntegrations
mirror of
https://github.com/Bayselonarrend/OpenIntegrations.git
synced 2025-08-10 22:41:43 +02:00
Рефакторинг, перенос ORM в ЗапросыSQL
This commit is contained in:
Anton Titovets
12249
service/dictionaries/en.json
vendored
12249
service/dictionaries/en.json
vendored
File diff suppressed because it is too large
Load Diff
252
src/ru/OInt/core/Modules/OPI_SQLite.os
vendored
252
src/ru/OInt/core/Modules/OPI_SQLite.os
vendored
@@ -98,6 +98,20 @@
|
||||
|
||||
КонецФункции
|
||||
|
||||
// Это коннектор !NOCLI
|
||||
// Проверяет, что значение является объектом внешней компоненты SQLite
|
||||
//
|
||||
// Параметры:
|
||||
// Значение - Произвольный - Значение для проверки - value
|
||||
//
|
||||
// Возвращаемое значение:
|
||||
// Булево - Это коннектор
|
||||
Функция ЭтоКоннектор(Знач Значение) Экспорт
|
||||
|
||||
Возврат Строка(ТипЗнч(Значение)) = "AddIn.OPI_SQLite.Main";
|
||||
|
||||
КонецФункции
|
||||
|
||||
// Выполнить запрос SQL
|
||||
// Выполняет произвольный SQL запрос
|
||||
//
|
||||
@@ -132,7 +146,7 @@
|
||||
КонецЕсли;
|
||||
|
||||
Результат = Коннектор.Execute(ТекстЗапроса, Параметры_, ФорсироватьРезультат);
|
||||
Результат = OPI_Инструменты.JsonВСтруктуру(Результат, Ложь);
|
||||
Результат = OPI_Инструменты.JsonВСтруктуру(Результат);
|
||||
|
||||
Возврат Результат;
|
||||
|
||||
@@ -148,34 +162,13 @@
|
||||
// Параметры:
|
||||
// Таблица - Строка - Имя таблицы - table
|
||||
// СтруктураКолонок - Структура Из КлючИЗначение - Структура колонок: Ключ > имя, Значение > Тип данных - cols
|
||||
// НеВыполнять - Булево - Истина > Не выполняет запрос, а возвращает текст SQL - noex
|
||||
// Соединение - Строка, Произвольный - Существующее соединение или путь к базе - db
|
||||
//
|
||||
// Возвращаемое значение:
|
||||
// Структура Из КлючИЗначение, Строка - Результат выполнения запроса или его текст
|
||||
Функция СоздатьТаблицу(Знач Таблица, Знач СтруктураКолонок, Знач НеВыполнять = Ложь, Знач Соединение = "") Экспорт
|
||||
|
||||
OPI_ПреобразованиеТипов.ПолучитьБулево(НеВыполнять);
|
||||
|
||||
ТекстОшибки = "Структура колонок не является валидной структурой ключ-значение";
|
||||
OPI_ПреобразованиеТипов.ПолучитьКоллекциюКлючИЗначение(СтруктураКолонок, ТекстОшибки);
|
||||
|
||||
Схема = OPI_ЗапросыSQL.ПустаяСхемаSQL("CREATE");
|
||||
|
||||
OPI_ЗапросыSQL.УстановитьИмяТаблицы(Схема, Таблица);
|
||||
|
||||
Для Каждого Колонка Из СтруктураКолонок Цикл
|
||||
OPI_ЗапросыSQL.ДобавитьКолонку(Схема, Колонка.Ключ, Колонка.Значение);
|
||||
КонецЦикла;
|
||||
|
||||
Запрос = OPI_ЗапросыSQL.СформироватьТекстSQL(Схема);
|
||||
|
||||
Если НеВыполнять Тогда
|
||||
Результат = Запрос;
|
||||
Иначе
|
||||
Результат = ВыполнитьЗапросSQL(Запрос, , , Соединение);
|
||||
КонецЕсли;
|
||||
Функция СоздатьТаблицу(Знач Таблица, Знач СтруктураКолонок, Знач Соединение = "") Экспорт
|
||||
|
||||
Результат = OPI_ЗапросыSQL.СоздатьТаблицу(OPI_SQLite, Таблица, СтруктураКолонок, Соединение);
|
||||
Возврат Результат;
|
||||
|
||||
КонецФункции
|
||||
@@ -193,84 +186,8 @@
|
||||
// Структура Из КлючИЗначение, Строка - Результат выполнения запроса
|
||||
Функция ДобавитьЗаписи(Знач Таблица, Знач МассивДанных, Знач Транзакция = Истина, Знач Соединение = "") Экспорт
|
||||
|
||||
OPI_ПреобразованиеТипов.ПолучитьМассив(МассивДанных);
|
||||
OPI_ПреобразованиеТипов.ПолучитьБулево(Транзакция);
|
||||
|
||||
Соединение = ОткрытьСоединение(Соединение);
|
||||
|
||||
Если Не ЭтоКоннектор(Соединение) Тогда
|
||||
Возврат Соединение;
|
||||
КонецЕсли;
|
||||
|
||||
Если Транзакция Тогда
|
||||
|
||||
Начало = ВыполнитьЗапросSQL("BEGIN TRANSACTION", , , Соединение);
|
||||
|
||||
Если Не Начало["result"] Тогда
|
||||
Возврат Начало;
|
||||
КонецЕсли;
|
||||
|
||||
КонецЕсли;
|
||||
|
||||
Счетчик = 0;
|
||||
СчетчикУспешных = 0;
|
||||
|
||||
Ошибка = Ложь;
|
||||
МассивОшибок = Новый Массив;
|
||||
ОшибкаКоллекции = "Invalid data";
|
||||
|
||||
СтруктураРезультата = Новый Структура;
|
||||
|
||||
Для Каждого Запись Из МассивДанных Цикл
|
||||
|
||||
Если Ошибка И Транзакция Тогда
|
||||
|
||||
Откат = ВыполнитьЗапросSQL("ROLLBACK", , , Соединение);
|
||||
|
||||
СчетчикУспешных = 0;
|
||||
СтруктураРезультата.Вставить("rollback", Откат);
|
||||
Прервать;
|
||||
|
||||
КонецЕсли;
|
||||
|
||||
Счетчик = Счетчик + 1;
|
||||
Ошибка = Ложь;
|
||||
|
||||
Попытка
|
||||
OPI_ПреобразованиеТипов.ПолучитьКоллекциюКлючИЗначение(Запись, ОшибкаКоллекции);
|
||||
Исключение
|
||||
МассивОшибок.Добавить(Новый Структура("row,error", Счетчик, ОшибкаКоллекции));
|
||||
Ошибка = Истина;
|
||||
Продолжить;
|
||||
КонецПопытки;
|
||||
|
||||
Результат = ДобавитьЗапись(Таблица, Запись, Соединение);
|
||||
|
||||
Если Результат["result"] Тогда
|
||||
|
||||
СчетчикУспешных = СчетчикУспешных + 1;
|
||||
|
||||
Иначе
|
||||
|
||||
МассивОшибок.Добавить(Новый Структура("row,error", Счетчик, Результат["error"]));
|
||||
Ошибка = Истина;
|
||||
|
||||
КонецЕсли;
|
||||
|
||||
КонецЦикла;
|
||||
|
||||
Если Транзакция И Не Ошибка Тогда
|
||||
|
||||
Завершение = ВыполнитьЗапросSQL("COMMIT", , , Соединение);
|
||||
СтруктураРезультата.Вставить("commit", Завершение);
|
||||
|
||||
КонецЕсли;
|
||||
|
||||
СтруктураРезультата.Вставить("result", МассивОшибок.Количество() = 0);
|
||||
СтруктураРезультата.Вставить("rows" , СчетчикУспешных);
|
||||
СтруктураРезультата.Вставить("errors", МассивОшибок);
|
||||
|
||||
Возврат СтруктураРезультата;
|
||||
Результат = OPI_ЗапросыSQL.ДобавитьЗаписи(OPI_SQLite, Таблица, МассивДанных, Транзакция, Соединение);
|
||||
Возврат Результат;
|
||||
|
||||
КонецФункции
|
||||
|
||||
@@ -294,19 +211,25 @@
|
||||
, Знач Количество = ""
|
||||
, Знач Соединение = "") Экспорт
|
||||
|
||||
Схема = OPI_ЗапросыSQL.ПустаяСхемаSQL("SELECT");
|
||||
Результат = OPI_ЗапросыSQL.ПолучитьЗаписи(OPI_SQLite, Таблица, Поля, Фильтры, Сортировка, Количество, Соединение);
|
||||
Возврат Результат;
|
||||
|
||||
OPI_ЗапросыSQL.УстановитьИмяТаблицы(Схема, Таблица);
|
||||
OPI_ЗапросыSQL.УстановитьЛимит(Схема, Количество);
|
||||
КонецФункции
|
||||
|
||||
ЗаполнитьПоля(Схема, Поля);
|
||||
ЗаполнитьФильтры(Схема, Фильтры);
|
||||
ЗаполнитьСортировку(Схема, Сортировка);
|
||||
|
||||
Запрос = OPI_ЗапросыSQL.СформироватьТекстSQL(Схема);
|
||||
|
||||
Результат = ВыполнитьЗапросSQL(Запрос, Схема["values"], , Соединение);
|
||||
// Обновить записи
|
||||
// Обновляет значение записей по выбранным критериям
|
||||
//
|
||||
// Параметры:
|
||||
// Таблица - Строка - Имя таблицы - table
|
||||
// СтруктураЗначений - Структура Из КлючИЗначение - Структура значений: Ключ > поле, Значение > значение поля - values
|
||||
// Фильтры - Массив Из Структура - Массив фильтров. См. ПолучитьСтруктуруФильтраЗаписей - filter
|
||||
// Соединение - Строка, Произвольный - Существующее соединение или путь к базе - db
|
||||
//
|
||||
// Возвращаемое значение:
|
||||
// Структура Из КлючИЗначение, Строка - Результат выполнения запроса
|
||||
Функция ОбновитьЗаписи(Знач Таблица, Знач СтруктураЗначений, Знач Фильтры = "", Знач Соединение = "") Экспорт
|
||||
|
||||
Результат = OPI_ЗапросыSQL.ОбновитьЗаписи(OPI_SQLite, Таблица, СтруктураЗначений, Фильтры, Соединение);
|
||||
Возврат Результат;
|
||||
|
||||
КонецФункции
|
||||
@@ -327,20 +250,7 @@
|
||||
// Структура Из КлючИЗначение - Элемент фильтра записей
|
||||
Функция ПолучитьСтруктуруФильтраЗаписей(Знач Пустая = Ложь) Экспорт
|
||||
|
||||
СтруктураФильтра = Новый Структура;
|
||||
|
||||
СтруктураФильтра.Вставить("field", "<имя поля для отбора>");
|
||||
СтруктураФильтра.Вставить("type" , "<тип сравнения>");
|
||||
СтруктураФильтра.Вставить("value", "<значение для сравнения>");
|
||||
СтруктураФильтра.Вставить("union", "<связь со следующим условием: AND, OR и пр.>");
|
||||
СтруктураФильтра.Вставить("raw" , "<истина - значение будет вставлено текстом, как есть, ложь - через параметр>");
|
||||
|
||||
Если Пустая Тогда
|
||||
СтруктураФильтра = OPI_Инструменты.ОчиститьКоллекциюРекурсивно(СтруктураФильтра);
|
||||
КонецЕсли;
|
||||
|
||||
//@skip-check constructor-function-return-section
|
||||
Возврат СтруктураФильтра;
|
||||
Возврат OPI_ЗапросыSQL.ПолучитьСтруктуруФильтраЗаписей(Пустая);
|
||||
|
||||
КонецФункции
|
||||
|
||||
@@ -415,94 +325,4 @@
|
||||
|
||||
КонецФункции
|
||||
|
||||
Функция ЭтоКоннектор(Знач Значение)
|
||||
|
||||
Возврат Строка(ТипЗнч(Значение)) = "AddIn.OPI_SQLite.Main";
|
||||
|
||||
КонецФункции
|
||||
|
||||
Функция ДобавитьЗапись(Знач Таблица, Знач Запись, Знач Соединение)
|
||||
|
||||
МассивПолей = Новый Массив;
|
||||
МассивЗначений = Новый Массив;
|
||||
|
||||
Схема = OPI_ЗапросыSQL.ПустаяСхемаSQL("INSERT");
|
||||
OPI_ЗапросыSQL.УстановитьИмяТаблицы(Схема, Таблица);
|
||||
|
||||
РазделитьКоллекциюДанных(Запись, МассивПолей, МассивЗначений);
|
||||
|
||||
Для Каждого Поле Из МассивПолей Цикл
|
||||
OPI_ЗапросыSQL.ДобавитьПоле(Схема, Поле);
|
||||
КонецЦикла;
|
||||
|
||||
Запрос = OPI_ЗапросыSQL.СформироватьТекстSQL(Схема);
|
||||
|
||||
Результат = ВыполнитьЗапросSQL(Запрос, МассивЗначений, , Соединение);
|
||||
|
||||
Возврат Результат;
|
||||
|
||||
КонецФункции
|
||||
|
||||
Процедура РазделитьКоллекциюДанных(Знач Запись, МассивПолей, МассивЗначений)
|
||||
|
||||
Для Каждого Элемент Из Запись Цикл
|
||||
|
||||
МассивПолей.Добавить(Элемент.Ключ);
|
||||
МассивЗначений.Добавить(Элемент.Значение);
|
||||
|
||||
КонецЦикла;
|
||||
|
||||
КонецПроцедуры
|
||||
|
||||
Процедура ЗаполнитьПоля(Схема, Знач Поля)
|
||||
|
||||
Если Не ЗначениеЗаполнено(Поля) Тогда
|
||||
Поля = "*";
|
||||
КонецЕсли;
|
||||
|
||||
OPI_ПреобразованиеТипов.ПолучитьМассив(Поля);
|
||||
|
||||
Для Каждого Поле Из Поля Цикл
|
||||
OPI_ЗапросыSQL.ДобавитьПоле(Схема, Поле);
|
||||
КонецЦикла;
|
||||
|
||||
КонецПроцедуры
|
||||
|
||||
Процедура ЗаполнитьФильтры(Схема, Знач Фильтры)
|
||||
|
||||
Если Не ЗначениеЗаполнено(Фильтры) Тогда
|
||||
Возврат;
|
||||
КонецЕсли;
|
||||
|
||||
OPI_ПреобразованиеТипов.ПолучитьМассив(Фильтры);
|
||||
|
||||
Для Каждого Фильтр Из Фильтры Цикл
|
||||
|
||||
OPI_ЗапросыSQL.ДобавитьОтбор(Схема
|
||||
, Фильтр["field"]
|
||||
, ?(Фильтр.Свойство("type"), Фильтр["type"], "=")
|
||||
, Фильтр["value"]
|
||||
, ?(Фильтр.Свойство("union"), Фильтр["union"], "AND")
|
||||
, ?(Фильтр.Свойство("raw"), Фильтр["raw"], Ложь));
|
||||
|
||||
КонецЦикла;
|
||||
|
||||
КонецПроцедуры
|
||||
|
||||
Процедура ЗаполнитьСортировку(Знач Схема, Знач Сортировка)
|
||||
|
||||
Если Не ЗначениеЗаполнено(Сортировка) Тогда
|
||||
Возврат;
|
||||
КонецЕсли;
|
||||
|
||||
OPI_ПреобразованиеТипов.ПолучитьКоллекцию(Сортировка);
|
||||
|
||||
Для Каждого Элемент Из Сортировка Цикл
|
||||
|
||||
OPI_ЗапросыSQL.ДобавитьСортировку(Схема, Элемент.Ключ, Элемент.Значение);
|
||||
|
||||
КонецЦикла;
|
||||
|
||||
КонецПроцедуры
|
||||
|
||||
#КонецОбласти
|
||||
|
||||
2
src/ru/OInt/lib.config
vendored
2
src/ru/OInt/lib.config
vendored
@@ -23,7 +23,7 @@
|
||||
<module name="OPI_YandexID" file="core/Modules/OPI_YandexID.os"/>
|
||||
<module name="OPI_YandexMarket" file="core/Modules/OPI_YandexMarket.os"/>
|
||||
<module name="OPI_YandexMetrika" file="core/Modules/OPI_YandexMetrika.os"/>
|
||||
<module name="OPI_ЗапросыSQL" file="tools/Modules/OPI_ЗапросыSQL.os"/>
|
||||
<module name="os" file="tools/Modules/os"/>
|
||||
<module name="OPI_Инструменты" file="tools/Modules/internal/Modules/OPI_Инструменты.os"/>
|
||||
<module name="OPI_Криптография" file="tools/Modules/internal/Modules/OPI_Криптография.os"/>
|
||||
<module name="OPI_ПолучениеДанныхТестов" file="tools/Modules/OPI_ПолучениеДанныхТестов.os"/>
|
||||
|
||||
@@ -16250,13 +16250,10 @@
|
||||
СтруктураКолонок.Вставить("created_at", "DATETIME");
|
||||
СтруктураКолонок.Вставить("data" , "BLOB");
|
||||
|
||||
Результат = OPI_SQLite.СоздатьТаблицу(Таблица, СтруктураКолонок, , База);
|
||||
Результат = OPI_SQLite.СоздатьТаблицу(Таблица, СтруктураКолонок, База);
|
||||
|
||||
// END
|
||||
|
||||
Текст = OPI_SQLite.СоздатьТаблицу(Таблица, СтруктураКолонок, Истина, База);
|
||||
OPI_ПолучениеДанныхТестов.ЗаписатьЛог(Текст, "СоздатьТаблицу (запрос)", "SQLite");
|
||||
|
||||
OPI_ПолучениеДанныхТестов.ЗаписатьЛог(Результат, "СоздатьТаблицу", "SQLite");
|
||||
OPI_ПолучениеДанныхТестов.Проверка_SQLiteУспех(Результат);
|
||||
|
||||
@@ -16264,7 +16261,7 @@
|
||||
СоответствиеКолонок.Вставить("id" , "INTEGER PRIMARY KEY");
|
||||
СоответствиеКолонок.Вставить("[Непонятная колонка]", "TEXT");
|
||||
|
||||
Результат = OPI_SQLite.СоздатьТаблицу("test1", СоответствиеКолонок, , База);
|
||||
Результат = OPI_SQLite.СоздатьТаблицу("test1", СоответствиеКолонок, База);
|
||||
|
||||
OPI_ПолучениеДанныхТестов.ЗаписатьЛог(Результат, "СоздатьТаблицу (непонятная колонка)", "SQLite");
|
||||
OPI_ПолучениеДанныхТестов.Проверка_SQLiteУспех(Результат);
|
||||
|
||||
730
src/ru/OInt/tools/Modules/os
vendored
Normal file
730
src/ru/OInt/tools/Modules/os
vendored
Normal file
@@ -0,0 +1,730 @@
|
||||
// OneScript: ./OInt/tools/Modules/os
|
||||
|
||||
// MIT License
|
||||
|
||||
// Copyright (c) 2023 Anton Tsitavets
|
||||
|
||||
// Permission is hereby granted, free of charge, to any person obtaining a copy
|
||||
// of this software and associated documentation files (the "Software"), to deal
|
||||
// in the Software without restriction, including without limitation the rights
|
||||
// to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
|
||||
// copies of the Software, and to permit persons to whom the Software is
|
||||
// furnished to do so, subject to the following conditions:
|
||||
|
||||
// The above copyright notice and this permission notice shall be included in all
|
||||
// copies or substantial portions of the Software.
|
||||
|
||||
// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
|
||||
// IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
|
||||
// FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
|
||||
// AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
|
||||
// LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
|
||||
// OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
|
||||
// SOFTWARE.
|
||||
|
||||
// https://github.com/Bayselonarrend/OpenIntegrations
|
||||
|
||||
// BSLLS:Typo-off
|
||||
// BSLLS:LatinAndCyrillicSymbolInWord-off
|
||||
// BSLLS:IncorrectLineBreak-off
|
||||
// BSLLS:NumberOfOptionalParams-off
|
||||
// BSLLS:UsingServiceTag-off
|
||||
// BSLLS:LineLength-off
|
||||
|
||||
//@skip-check module-structure-top-region
|
||||
//@skip-check module-structure-method-in-regions
|
||||
//@skip-check wrong-string-literal-content
|
||||
//@skip-check method-too-many-params
|
||||
//@skip-check constructor-function-return-section
|
||||
|
||||
// Раскомментировать, если выполняется OneScript
|
||||
#Использовать "./internal"
|
||||
|
||||
#Область СлужебныйПрограммныйИнтерфейс
|
||||
|
||||
Функция СоздатьТаблицу(Знач Модуль, Знач Таблица, Знач СтруктураКолонок, Знач Соединение = "") Экспорт
|
||||
|
||||
ТекстОшибки = "Структура колонок не является валидной структурой ключ-значение";
|
||||
OPI_ПреобразованиеТипов.ПолучитьКоллекциюКлючИЗначение(СтруктураКолонок, ТекстОшибки);
|
||||
|
||||
Схема = ПустаяСхемаSQL("CREATE");
|
||||
|
||||
УстановитьИмяТаблицы(Схема, Таблица);
|
||||
|
||||
Для Каждого Колонка Из СтруктураКолонок Цикл
|
||||
ДобавитьКолонку(Схема, Колонка.Ключ, Колонка.Значение);
|
||||
КонецЦикла;
|
||||
|
||||
Запрос = СформироватьТекстSQL(Схема);
|
||||
Результат = Модуль.ВыполнитьЗапросSQL(Запрос, , , Соединение);
|
||||
|
||||
Возврат Результат;
|
||||
|
||||
КонецФункции
|
||||
|
||||
Функция ДобавитьЗаписи(Знач Модуль
|
||||
, Знач Таблица
|
||||
, Знач МассивДанных
|
||||
, Знач Транзакция = Истина
|
||||
, Знач Соединение = "") Экспорт
|
||||
|
||||
OPI_ПреобразованиеТипов.ПолучитьМассив(МассивДанных);
|
||||
OPI_ПреобразованиеТипов.ПолучитьБулево(Транзакция);
|
||||
|
||||
Соединение = Модуль.ОткрытьСоединение(Соединение);
|
||||
|
||||
Если Не Модуль.ЭтоКоннектор(Соединение) Тогда
|
||||
Возврат Соединение;
|
||||
КонецЕсли;
|
||||
|
||||
Если Транзакция Тогда
|
||||
|
||||
Начало = Модуль.ВыполнитьЗапросSQL("BEGIN TRANSACTION", , , Соединение);
|
||||
|
||||
Если Не Начало["result"] Тогда
|
||||
Возврат Начало;
|
||||
КонецЕсли;
|
||||
|
||||
КонецЕсли;
|
||||
|
||||
Счетчик = 0;
|
||||
СчетчикУспешных = 0;
|
||||
|
||||
Ошибка = Ложь;
|
||||
МассивОшибок = Новый Массив;
|
||||
ОшибкаКоллекции = "Invalid data";
|
||||
|
||||
СтруктураРезультата = Новый Структура;
|
||||
|
||||
Для Каждого Запись Из МассивДанных Цикл
|
||||
|
||||
Если Ошибка И Транзакция Тогда
|
||||
|
||||
Откат = Модуль.ВыполнитьЗапросSQL("ROLLBACK", , , Соединение);
|
||||
|
||||
СчетчикУспешных = 0;
|
||||
СтруктураРезультата.Вставить("rollback", Откат);
|
||||
Прервать;
|
||||
|
||||
КонецЕсли;
|
||||
|
||||
Счетчик = Счетчик + 1;
|
||||
Ошибка = Ложь;
|
||||
|
||||
Попытка
|
||||
OPI_ПреобразованиеТипов.ПолучитьКоллекциюКлючИЗначение(Запись, ОшибкаКоллекции);
|
||||
Исключение
|
||||
МассивОшибок.Добавить(Новый Структура("row,error", Счетчик, ОшибкаКоллекции));
|
||||
Ошибка = Истина;
|
||||
Продолжить;
|
||||
КонецПопытки;
|
||||
|
||||
Результат = ДобавитьЗапись(Модуль, Таблица, Запись, Соединение);
|
||||
|
||||
Если Результат["result"] Тогда
|
||||
|
||||
СчетчикУспешных = СчетчикУспешных + 1;
|
||||
|
||||
Иначе
|
||||
|
||||
МассивОшибок.Добавить(Новый Структура("row,error", Счетчик, Результат["error"]));
|
||||
Ошибка = Истина;
|
||||
|
||||
КонецЕсли;
|
||||
|
||||
КонецЦикла;
|
||||
|
||||
Если Транзакция И Не Ошибка Тогда
|
||||
|
||||
Завершение = Модуль.ВыполнитьЗапросSQL("COMMIT", , , Соединение);
|
||||
СтруктураРезультата.Вставить("commit", Завершение);
|
||||
|
||||
КонецЕсли;
|
||||
|
||||
СтруктураРезультата.Вставить("result", МассивОшибок.Количество() = 0);
|
||||
СтруктураРезультата.Вставить("rows" , СчетчикУспешных);
|
||||
СтруктураРезультата.Вставить("errors", МассивОшибок);
|
||||
|
||||
Возврат СтруктураРезультата;
|
||||
|
||||
КонецФункции
|
||||
|
||||
Функция ПолучитьЗаписи(Знач Модуль
|
||||
, Знач Таблица
|
||||
, Знач Поля = "*"
|
||||
, Знач Фильтры = ""
|
||||
, Знач Сортировка = ""
|
||||
, Знач Количество = ""
|
||||
, Знач Соединение = "") Экспорт
|
||||
|
||||
Схема = ПустаяСхемаSQL("SELECT");
|
||||
|
||||
УстановитьИмяТаблицы(Схема, Таблица);
|
||||
УстановитьНастройкиSelect(Схема, Поля, Фильтры, Сортировка, Количество);
|
||||
|
||||
Запрос = СформироватьТекстSQL(Схема);
|
||||
|
||||
Результат = Модуль.ВыполнитьЗапросSQL(Запрос, Схема["values"], , Соединение);
|
||||
|
||||
Возврат Результат;
|
||||
|
||||
КонецФункции
|
||||
|
||||
Функция ОбновитьЗаписи(Знач Модуль
|
||||
, Знач Таблица
|
||||
, Знач МассивЗначений
|
||||
, Знач Фильтры = ""
|
||||
, Знач Соединение = "") Экспорт
|
||||
|
||||
Схема = ПустаяСхемаSQL("UPDATE");
|
||||
|
||||
УстановитьИмяТаблицы(Схема, Таблица);
|
||||
|
||||
Запрос = СформироватьТекстSQL(Схема);
|
||||
Результат = Модуль.ВыполнитьЗапросSQL(Запрос, Схема["values"], , Соединение);
|
||||
|
||||
Возврат Результат;
|
||||
|
||||
КонецФункции
|
||||
|
||||
Функция ПолучитьСтруктуруФильтраЗаписей(Знач Пустая = Ложь) Экспорт
|
||||
|
||||
СтруктураФильтра = Новый Структура;
|
||||
|
||||
СтруктураФильтра.Вставить("field", "<имя поля для отбора>");
|
||||
СтруктураФильтра.Вставить("type" , "<тип сравнения>");
|
||||
СтруктураФильтра.Вставить("value", "<значение для сравнения>");
|
||||
СтруктураФильтра.Вставить("union", "<связь со следующим условием: AND, OR и пр.>");
|
||||
СтруктураФильтра.Вставить("raw" , "<истина - значение будет вставлено текстом, как есть, ложь - через параметр>");
|
||||
|
||||
Если Пустая Тогда
|
||||
СтруктураФильтра = OPI_Инструменты.ОчиститьКоллекциюРекурсивно(СтруктураФильтра);
|
||||
КонецЕсли;
|
||||
|
||||
//@skip-check constructor-function-return-section
|
||||
Возврат СтруктураФильтра;
|
||||
|
||||
КонецФункции
|
||||
|
||||
#КонецОбласти
|
||||
|
||||
#Область СлужебныеПроцедурыИФункции
|
||||
|
||||
#Область Схемы
|
||||
|
||||
Функция ПустаяСхемаSelect()
|
||||
|
||||
Схема = Новый Структура("type", "SELECT");
|
||||
|
||||
Схема.Вставить("table" , "");
|
||||
Схема.Вставить("filter" , Новый Массив);
|
||||
Схема.Вставить("order" , Новый Массив);
|
||||
Схема.Вставить("limit" , 0);
|
||||
Схема.Вставить("set" , Новый Массив);
|
||||
Схема.Вставить("values" , Новый Массив);
|
||||
|
||||
Возврат Схема;
|
||||
|
||||
КонецФункции
|
||||
|
||||
Функция ПустаяСхемаInsert()
|
||||
|
||||
Схема = Новый Структура("type", "INSERT");
|
||||
|
||||
Схема.Вставить("table", "");
|
||||
Схема.Вставить("set" , Новый Массив);
|
||||
|
||||
Возврат Схема;
|
||||
|
||||
КонецФункции
|
||||
|
||||
Функция ПустаяСхемаUpdate()
|
||||
|
||||
Схема = Новый Структура("type", "UPDATE");
|
||||
|
||||
Схема.Вставить("table" , "");
|
||||
Схема.Вставить("set" , Новый Массив);
|
||||
Схема.Вставить("filter", Новый Массив);
|
||||
Схема.Вставить("values" , Новый Массив);
|
||||
|
||||
Возврат Схема;
|
||||
|
||||
КонецФункции
|
||||
|
||||
Функция ПустаяСхемаDelete()
|
||||
|
||||
Схема = Новый Структура("type", "DELETE");
|
||||
|
||||
Схема.Вставить("table" , "");
|
||||
Схема.Вставить("filter", Новый Массив);
|
||||
|
||||
Возврат Схема;
|
||||
|
||||
КонецФункции
|
||||
|
||||
Функция ПустаяСхемаCreate()
|
||||
|
||||
Схема = Новый Структура("type", "CREATE");
|
||||
|
||||
Схема.Вставить("table" , "");
|
||||
Схема.Вставить("columns", Новый Массив);
|
||||
|
||||
Возврат Схема;
|
||||
|
||||
КонецФункции
|
||||
|
||||
#КонецОбласти
|
||||
|
||||
#Область Процессоры
|
||||
|
||||
Функция СформироватьТекстSelect(Знач Схема)
|
||||
|
||||
ПроверитьОбязательныеПоляСхемы(Схема, "table,filter,order,limit,set");
|
||||
|
||||
Таблица = Схема["table"];
|
||||
Поля = Схема["set"];
|
||||
Фильтры = Схема["filter"];
|
||||
Сортировка = Схема["order"];
|
||||
Количество = Схема["limit"];
|
||||
|
||||
ШаблонSQL = "SELECT %1 FROM %2
|
||||
|%3";
|
||||
|
||||
БлокНастроек = СформироватьТекстНастроекSelect(Фильтры, Сортировка, Количество);
|
||||
|
||||
ТекстSQL = СтрШаблон(ШаблонSQL, СтрСоединить(Поля, ", "), Таблица, БлокНастроек);
|
||||
|
||||
Возврат ТекстSQL;
|
||||
|
||||
КонецФункции
|
||||
|
||||
Функция СформироватьТекстInsert(Знач Схема)
|
||||
|
||||
ПроверитьОбязательныеПоляСхемы(Схема, "table,set");
|
||||
|
||||
Таблица = Схема["table"];
|
||||
Поля = Схема["set"];
|
||||
|
||||
ШаблонSQL = "INSERT INTO %1 (%2) VALUES (%3)";
|
||||
|
||||
Параметры = Новый Массив;
|
||||
|
||||
Для Н = 1 По Поля.Количество() Цикл
|
||||
Параметры.Добавить("?" + OPI_Инструменты.ЧислоВСтроку(Н));
|
||||
КонецЦикла;
|
||||
|
||||
ТекстSQL = СтрШаблон(ШаблонSQL
|
||||
, Таблица
|
||||
, СтрСоединить(Поля, ", ")
|
||||
, СтрСоединить(Параметры, ", "));
|
||||
|
||||
Возврат ТекстSQL;
|
||||
|
||||
КонецФункции
|
||||
|
||||
Функция СформироватьТекстUpdate(Знач Схема)
|
||||
|
||||
ТекстSQL = "";
|
||||
|
||||
Возврат ТекстSQL;
|
||||
|
||||
КонецФункции
|
||||
|
||||
Функция СформироватьТекстDelete(Знач Схема)
|
||||
|
||||
ТекстSQL = "";
|
||||
|
||||
Возврат ТекстSQL;
|
||||
|
||||
КонецФункции
|
||||
|
||||
Функция СформироватьТекстCreate(Знач Схема)
|
||||
|
||||
ПроверитьОбязательныеПоляСхемы(Схема, "table,columns");
|
||||
|
||||
Таблица = Схема["table"];
|
||||
Колонки = Схема["columns"];
|
||||
|
||||
ШаблонSQL = "CREATE TABLE %1 (
|
||||
| %2
|
||||
| )";
|
||||
|
||||
ШаблонКолонки = "%1 %2";
|
||||
|
||||
МассивОписанийКолонок = Новый Массив;
|
||||
|
||||
Для Каждого Колонка Из Колонки Цикл
|
||||
Для Каждого Элемент Из Колонка Цикл
|
||||
МассивОписанийКолонок.Добавить(СтрШаблон(ШаблонКолонки, Элемент.Ключ, Элемент.Значение));
|
||||
КонецЦикла;
|
||||
КонецЦикла;
|
||||
|
||||
ОписанияКолонок = СтрСоединить(МассивОписанийКолонок, "," + Символы.ПС);
|
||||
|
||||
ТекстSQL = СтрШаблон(ШаблонSQL, Таблица, ОписанияКолонок);
|
||||
|
||||
Возврат ТекстSQL;
|
||||
|
||||
КонецФункции
|
||||
|
||||
#КонецОбласти
|
||||
|
||||
#Область Вспомогательные
|
||||
|
||||
Функция ПустаяСхемаSQL(Знач Действие)
|
||||
|
||||
OPI_ПреобразованиеТипов.ПолучитьСтроку(Действие);
|
||||
|
||||
Действие = вРег(Действие);
|
||||
|
||||
Если Действие = "SELECT" Тогда
|
||||
|
||||
Схема = ПустаяСхемаSelect();
|
||||
|
||||
ИначеЕсли Действие = "INSERT" Тогда
|
||||
|
||||
Схема = ПустаяСхемаInsert();
|
||||
|
||||
ИначеЕсли Действие = "UPDATE" Тогда
|
||||
|
||||
Схема = ПустаяСхемаUpdate();
|
||||
|
||||
ИначеЕсли Действие = "DELETE" Тогда
|
||||
|
||||
Схема = ПустаяСхемаDelete();
|
||||
|
||||
ИначеЕсли Действие = "CREATE" Тогда
|
||||
|
||||
Схема = ПустаяСхемаCreate();
|
||||
|
||||
Иначе
|
||||
|
||||
Схема = Новый Структура;
|
||||
|
||||
КонецЕсли;
|
||||
|
||||
Возврат Схема;
|
||||
|
||||
КонецФункции
|
||||
|
||||
Функция СформироватьТекстSQL(Знач Схема)
|
||||
|
||||
ТекстОшибки = "Переданное значение не является валидной схемой SQL запроса";
|
||||
OPI_ПреобразованиеТипов.ПолучитьКоллекциюКлючИЗначение(Схема, ТекстОшибки);
|
||||
|
||||
ТипСхемы = "";
|
||||
|
||||
Если Не OPI_Инструменты.ПолеКоллекцииСуществует(Схема, "type", ТипСхемы) Тогда
|
||||
ВызватьИсключение ТекстОшибки;
|
||||
КонецЕсли;
|
||||
|
||||
ТипСхемы = вРег(ТипСхемы);
|
||||
|
||||
Если ТипСхемы = "SELECT" Тогда
|
||||
|
||||
ТекстЗапроса = СформироватьТекстSelect(Схема);
|
||||
|
||||
ИначеЕсли ТипСхемы = "INSERT" Тогда
|
||||
|
||||
ТекстЗапроса = СформироватьТекстInsert(Схема);
|
||||
|
||||
ИначеЕсли ТипСхемы = "UPDATE" Тогда
|
||||
|
||||
ТекстЗапроса = СформироватьТекстUpdate(Схема);
|
||||
|
||||
ИначеЕсли ТипСхемы = "DELETE" Тогда
|
||||
|
||||
ТекстЗапроса = СформироватьТекстDelete(Схема);
|
||||
|
||||
ИначеЕсли ТипСхемы = "CREATE" Тогда
|
||||
|
||||
ТекстЗапроса = СформироватьТекстCreate(Схема);
|
||||
|
||||
Иначе
|
||||
|
||||
ТекстЗапроса = "";
|
||||
|
||||
КонецЕсли;
|
||||
|
||||
Возврат ТекстЗапроса;
|
||||
|
||||
КонецФункции
|
||||
|
||||
Функция СформироватьТекстНастроекSelect(Знач Фильтры, Знач Сортировка, Знач Количество)
|
||||
|
||||
ШаблонБлока = "%1
|
||||
|%2
|
||||
|%3";
|
||||
|
||||
ТекстФильтра = СформироватьТекстФильтра(Фильтры);
|
||||
ТекстСортировки = СформироватьТекстСортировки(Сортировка);
|
||||
ТекстКоличества = СформироватьТекстКоличества(Количество);
|
||||
|
||||
ТекстБлока = СтрШаблон(ШаблонБлока, ТекстФильтра, ТекстСортировки, ТекстКоличества);
|
||||
|
||||
Возврат ТекстБлока;
|
||||
|
||||
КонецФункции
|
||||
|
||||
Функция СформироватьТекстФильтра(Знач Фильтры)
|
||||
|
||||
Если Не ЗначениеЗаполнено(Фильтры) Тогда
|
||||
Возврат "";
|
||||
КонецЕсли;
|
||||
|
||||
ТекстФильтров = "WHERE %1";
|
||||
|
||||
МассивФильтров = Новый Массив;
|
||||
|
||||
Счетчик = 1;
|
||||
Всего = Фильтры.Количество();
|
||||
|
||||
Для Каждого Фильтр Из Фильтры Цикл
|
||||
|
||||
ТекущийТекст = "%1 %2 %3 %4";
|
||||
|
||||
Поле = Фильтр["field"];
|
||||
Тип = Фильтр["type"];
|
||||
Значение = Фильтр["value"];
|
||||
Соединение = Фильтр["union"];
|
||||
Соединение = ?(ЗначениеЗаполнено(Соединение), Соединение, "AND");
|
||||
|
||||
Если Счетчик = Всего Тогда
|
||||
Соединение = "";
|
||||
КонецЕсли;
|
||||
|
||||
ТекущийТекст = СтрШаблон(ТекущийТекст, Поле, Тип, Значение, Соединение);
|
||||
МассивФильтров.Добавить(ТекущийТекст);
|
||||
|
||||
Счетчик = Счетчик + 1;
|
||||
|
||||
КонецЦикла;
|
||||
|
||||
ТекстФильтров = СтрШаблон(ТекстФильтров, СтрСоединить(МассивФильтров, " "));
|
||||
|
||||
Возврат ТекстФильтров;
|
||||
|
||||
КонецФункции
|
||||
|
||||
Функция СформироватьТекстСортировки(Знач Сортировка)
|
||||
|
||||
Если Не ЗначениеЗаполнено(Сортировка) Тогда
|
||||
Возврат "";
|
||||
КонецЕсли;
|
||||
|
||||
ТекстСортировки = "ORDER BY %1";
|
||||
|
||||
МассивСортировки = Новый Массив;
|
||||
|
||||
Для Каждого Элемент Из Сортировка Цикл
|
||||
|
||||
МассивСортировки.Добавить(Элемент["field"] + " " + Элемент["type"]);
|
||||
|
||||
КонецЦикла;
|
||||
|
||||
ТекстСортировки = СтрШаблон(ТекстСортировки, СтрСоединить(МассивСортировки, ", "));
|
||||
|
||||
Возврат ТекстСортировки;
|
||||
|
||||
КонецФункции
|
||||
|
||||
Функция СформироватьТекстКоличества(Знач Количество)
|
||||
|
||||
Если Не ЗначениеЗаполнено(Количество) Тогда
|
||||
Возврат "";
|
||||
КонецЕсли;
|
||||
|
||||
ТекстКоличества = "LIMIT %1";
|
||||
ТекстКоличества = СтрШаблон(ТекстКоличества, OPI_Инструменты.ЧислоВСтроку(Количество));
|
||||
|
||||
Возврат ТекстКоличества;
|
||||
|
||||
КонецФункции
|
||||
|
||||
Функция ДобавитьЗапись(Знач Модуль, Знач Таблица, Знач Запись, Знач Соединение)
|
||||
|
||||
МассивПолей = Новый Массив;
|
||||
МассивЗначений = Новый Массив;
|
||||
|
||||
Схема = ПустаяСхемаSQL("INSERT");
|
||||
УстановитьИмяТаблицы(Схема, Таблица);
|
||||
|
||||
РазделитьКоллекциюДанных(Запись, МассивПолей, МассивЗначений);
|
||||
|
||||
Для Каждого Поле Из МассивПолей Цикл
|
||||
ДобавитьПоле(Схема, Поле);
|
||||
КонецЦикла;
|
||||
|
||||
Запрос = СформироватьТекстSQL(Схема);
|
||||
|
||||
Результат = Модуль.ВыполнитьЗапросSQL(Запрос, МассивЗначений, , Соединение);
|
||||
|
||||
Возврат Результат;
|
||||
|
||||
КонецФункции
|
||||
|
||||
Процедура РазделитьКоллекциюДанных(Знач Запись, МассивПолей, МассивЗначений)
|
||||
|
||||
Для Каждого Элемент Из Запись Цикл
|
||||
|
||||
МассивПолей.Добавить(Элемент.Ключ);
|
||||
МассивЗначений.Добавить(Элемент.Значение);
|
||||
|
||||
КонецЦикла;
|
||||
|
||||
КонецПроцедуры
|
||||
|
||||
Процедура ЗаполнитьПоля(Схема, Знач Поля)
|
||||
|
||||
Если Не ЗначениеЗаполнено(Поля) Тогда
|
||||
Поля = "*";
|
||||
КонецЕсли;
|
||||
|
||||
OPI_ПреобразованиеТипов.ПолучитьМассив(Поля);
|
||||
|
||||
Для Каждого Поле Из Поля Цикл
|
||||
ДобавитьПоле(Схема, Поле);
|
||||
КонецЦикла;
|
||||
|
||||
КонецПроцедуры
|
||||
|
||||
Процедура ЗаполнитьФильтры(Схема, Знач Фильтры)
|
||||
|
||||
Если Не ЗначениеЗаполнено(Фильтры) Тогда
|
||||
Возврат;
|
||||
КонецЕсли;
|
||||
|
||||
OPI_ПреобразованиеТипов.ПолучитьМассив(Фильтры);
|
||||
|
||||
Для Каждого Фильтр Из Фильтры Цикл
|
||||
|
||||
ДобавитьОтбор(Схема
|
||||
, Фильтр["field"]
|
||||
, ?(Фильтр.Свойство("type"), Фильтр["type"], "=")
|
||||
, Фильтр["value"]
|
||||
, ?(Фильтр.Свойство("union"), Фильтр["union"], "AND")
|
||||
, ?(Фильтр.Свойство("raw"), Фильтр["raw"], Ложь));
|
||||
|
||||
КонецЦикла;
|
||||
|
||||
КонецПроцедуры
|
||||
|
||||
Процедура ЗаполнитьСортировку(Знач Схема, Знач Сортировка)
|
||||
|
||||
Если Не ЗначениеЗаполнено(Сортировка) Тогда
|
||||
Возврат;
|
||||
КонецЕсли;
|
||||
|
||||
OPI_ПреобразованиеТипов.ПолучитьКоллекцию(Сортировка);
|
||||
|
||||
Для Каждого Элемент Из Сортировка Цикл
|
||||
|
||||
ДобавитьСортировку(Схема, Элемент.Ключ, Элемент.Значение);
|
||||
|
||||
КонецЦикла;
|
||||
|
||||
КонецПроцедуры
|
||||
|
||||
Процедура ПроверитьОбязательныеПоляСхемы(Схема, Знач Поля)
|
||||
|
||||
МассивОбязательныхПолей = СтрРазделить(Поля, ",");
|
||||
МассивОтсутствующих = OPI_Инструменты.НайтиОтсутствующиеПоляКоллекции(Схема, МассивОбязательныхПолей);
|
||||
|
||||
Если ЗначениеЗаполнено(МассивОтсутствующих) Тогда
|
||||
ВызватьИсключение "Отсутствуют необходимые поля схемы: " + СтрСоединить(МассивОтсутствующих, ", ");
|
||||
КонецЕсли;
|
||||
|
||||
КонецПроцедуры
|
||||
|
||||
Процедура ДобавитьКолонку(Схема, Знач Имя, Знач Тип) Экспорт
|
||||
|
||||
OPI_ПреобразованиеТипов.ПолучитьСтроку(Имя);
|
||||
OPI_ПреобразованиеТипов.ПолучитьСтроку(Тип);
|
||||
|
||||
Если Не Схема["type"] = "CREATE" Тогда
|
||||
Возврат;
|
||||
КонецЕсли;
|
||||
|
||||
СоответствиеКолонки = Новый Соответствие;
|
||||
СоответствиеКолонки.Вставить(Имя, Тип);
|
||||
|
||||
Схема["columns"].Добавить(СоответствиеКолонки);
|
||||
|
||||
КонецПроцедуры
|
||||
|
||||
Процедура ДобавитьПоле(Схема, Знач Имя) Экспорт
|
||||
|
||||
OPI_ПреобразованиеТипов.ПолучитьСтроку(Имя);
|
||||
|
||||
Схема["set"].Добавить(Имя);
|
||||
|
||||
КонецПроцедуры
|
||||
|
||||
Процедура ДобавитьОтбор(Схема, Знач Поле, Знач Тип, Знач Значение, Знач Группировка, Знач КакЕсть)
|
||||
|
||||
OPI_ПреобразованиеТипов.ПолучитьСтроку(Поле);
|
||||
OPI_ПреобразованиеТипов.ПолучитьСтроку(Тип);
|
||||
OPI_ПреобразованиеТипов.ПолучитьСтроку(Группировка);
|
||||
OPI_ПреобразованиеТипов.ПолучитьБулево(КакЕсть);
|
||||
|
||||
ОсновнаяСтруктура = Новый Структура("field,type,union"
|
||||
, Поле
|
||||
, Тип
|
||||
, Группировка);
|
||||
|
||||
Если КакЕсть Тогда
|
||||
|
||||
ОсновнаяСтруктура.Вставить("value", Строка(Значение));
|
||||
|
||||
Иначе
|
||||
|
||||
Схема["values"].Добавить(Значение);
|
||||
|
||||
ПорядковыйНомер = Схема["values"].Количество();
|
||||
ОсновнаяСтруктура.Вставить("value", "?" + OPI_Инструменты.ЧислоВСтроку(ПорядковыйНомер));
|
||||
|
||||
КонецЕсли;
|
||||
|
||||
|
||||
Схема["filter"].Добавить(ОсновнаяСтруктура);
|
||||
|
||||
КонецПроцедуры
|
||||
|
||||
Процедура ДобавитьСортировку(Схема, Знач Поле, Знач Тип)
|
||||
|
||||
OPI_ПреобразованиеТипов.ПолучитьСтроку(Поле);
|
||||
OPI_ПреобразованиеТипов.ПолучитьСтроку(Тип);
|
||||
|
||||
Схема["order"].Добавить(Новый Структура("field,type", Поле, Тип));
|
||||
|
||||
КонецПроцедуры
|
||||
|
||||
Процедура УстановитьИмяТаблицы(Схема, Знач Имя)
|
||||
|
||||
OPI_ПреобразованиеТипов.ПолучитьСтроку(Имя);
|
||||
|
||||
Схема.Вставить("table", Имя);
|
||||
|
||||
КонецПроцедуры
|
||||
|
||||
Процедура УстановитьЛимит(Схема, Знач Количество)
|
||||
|
||||
OPI_ПреобразованиеТипов.ПолучитьЧисло(Количество);
|
||||
|
||||
Схема.Вставить("limit", Количество);
|
||||
|
||||
КонецПроцедуры
|
||||
|
||||
Процедура УстановитьНастройкиSelect(Схема, Знач Поля, Знач Фильтры, Знач Сортировка, Знач Количество)
|
||||
|
||||
УстановитьЛимит(Схема, Количество);
|
||||
|
||||
ЗаполнитьПоля(Схема, Поля);
|
||||
ЗаполнитьФильтры(Схема, Фильтры);
|
||||
ЗаполнитьСортировку(Схема, Сортировка);
|
||||
|
||||
КонецПроцедуры
|
||||
|
||||
#КонецОбласти
|
||||
|
||||
#КонецОбласти
|
||||
@@ -1,4 +1,4 @@
|
||||
// OneScript: ./OInt/core/Modules/OPI_SQLite.os
|
||||
// OneScript: ./OInt/core/Modules/OPI_SQLite.os
|
||||
// Lib: SQLite
|
||||
// CLI: sqlite
|
||||
|
||||
@@ -98,6 +98,20 @@
|
||||
|
||||
КонецФункции
|
||||
|
||||
// Это коннектор !NOCLI
|
||||
// Проверяет, что значение является объектом внешней компоненты SQLite
|
||||
//
|
||||
// Параметры:
|
||||
// Значение - Произвольный - Значение для проверки - value
|
||||
//
|
||||
// Возвращаемое значение:
|
||||
// Булево - Это коннектор
|
||||
Функция ЭтоКоннектор(Знач Значение) Экспорт
|
||||
|
||||
Возврат Строка(ТипЗнч(Значение)) = "AddIn.OPI_SQLite.Main";
|
||||
|
||||
КонецФункции
|
||||
|
||||
// Выполнить запрос SQL
|
||||
// Выполняет произвольный SQL запрос
|
||||
//
|
||||
@@ -132,7 +146,7 @@
|
||||
КонецЕсли;
|
||||
|
||||
Результат = Коннектор.Execute(ТекстЗапроса, Параметры_, ФорсироватьРезультат);
|
||||
Результат = OPI_Инструменты.JsonВСтруктуру(Результат, Ложь);
|
||||
Результат = OPI_Инструменты.JsonВСтруктуру(Результат);
|
||||
|
||||
Возврат Результат;
|
||||
|
||||
@@ -148,34 +162,13 @@
|
||||
// Параметры:
|
||||
// Таблица - Строка - Имя таблицы - table
|
||||
// СтруктураКолонок - Структура Из КлючИЗначение - Структура колонок: Ключ > имя, Значение > Тип данных - cols
|
||||
// НеВыполнять - Булево - Истина > Не выполняет запрос, а возвращает текст SQL - noex
|
||||
// Соединение - Строка, Произвольный - Существующее соединение или путь к базе - db
|
||||
//
|
||||
// Возвращаемое значение:
|
||||
// Структура Из КлючИЗначение, Строка - Результат выполнения запроса или его текст
|
||||
Функция СоздатьТаблицу(Знач Таблица, Знач СтруктураКолонок, Знач НеВыполнять = Ложь, Знач Соединение = "") Экспорт
|
||||
|
||||
OPI_ПреобразованиеТипов.ПолучитьБулево(НеВыполнять);
|
||||
|
||||
ТекстОшибки = "Структура колонок не является валидной структурой ключ-значение";
|
||||
OPI_ПреобразованиеТипов.ПолучитьКоллекциюКлючИЗначение(СтруктураКолонок, ТекстОшибки);
|
||||
|
||||
Схема = OPI_ЗапросыSQL.ПустаяСхемаSQL("CREATE");
|
||||
|
||||
OPI_ЗапросыSQL.УстановитьИмяТаблицы(Схема, Таблица);
|
||||
|
||||
Для Каждого Колонка Из СтруктураКолонок Цикл
|
||||
OPI_ЗапросыSQL.ДобавитьКолонку(Схема, Колонка.Ключ, Колонка.Значение);
|
||||
КонецЦикла;
|
||||
|
||||
Запрос = OPI_ЗапросыSQL.СформироватьТекстSQL(Схема);
|
||||
|
||||
Если НеВыполнять Тогда
|
||||
Результат = Запрос;
|
||||
Иначе
|
||||
Результат = ВыполнитьЗапросSQL(Запрос, , , Соединение);
|
||||
КонецЕсли;
|
||||
Функция СоздатьТаблицу(Знач Таблица, Знач СтруктураКолонок, Знач Соединение = "") Экспорт
|
||||
|
||||
Результат = OPI_ЗапросыSQL.СоздатьТаблицу(OPI_SQLite, Таблица, СтруктураКолонок, Соединение);
|
||||
Возврат Результат;
|
||||
|
||||
КонецФункции
|
||||
@@ -193,84 +186,8 @@
|
||||
// Структура Из КлючИЗначение, Строка - Результат выполнения запроса
|
||||
Функция ДобавитьЗаписи(Знач Таблица, Знач МассивДанных, Знач Транзакция = Истина, Знач Соединение = "") Экспорт
|
||||
|
||||
OPI_ПреобразованиеТипов.ПолучитьМассив(МассивДанных);
|
||||
OPI_ПреобразованиеТипов.ПолучитьБулево(Транзакция);
|
||||
|
||||
Соединение = ОткрытьСоединение(Соединение);
|
||||
|
||||
Если Не ЭтоКоннектор(Соединение) Тогда
|
||||
Возврат Соединение;
|
||||
КонецЕсли;
|
||||
|
||||
Если Транзакция Тогда
|
||||
|
||||
Начало = ВыполнитьЗапросSQL("BEGIN TRANSACTION", , , Соединение);
|
||||
|
||||
Если Не Начало["result"] Тогда
|
||||
Возврат Начало;
|
||||
КонецЕсли;
|
||||
|
||||
КонецЕсли;
|
||||
|
||||
Счетчик = 0;
|
||||
СчетчикУспешных = 0;
|
||||
|
||||
Ошибка = Ложь;
|
||||
МассивОшибок = Новый Массив;
|
||||
ОшибкаКоллекции = "Invalid data";
|
||||
|
||||
СтруктураРезультата = Новый Структура;
|
||||
|
||||
Для Каждого Запись Из МассивДанных Цикл
|
||||
|
||||
Если Ошибка И Транзакция Тогда
|
||||
|
||||
Откат = ВыполнитьЗапросSQL("ROLLBACK", , , Соединение);
|
||||
|
||||
СчетчикУспешных = 0;
|
||||
СтруктураРезультата.Вставить("rollback", Откат);
|
||||
Прервать;
|
||||
|
||||
КонецЕсли;
|
||||
|
||||
Счетчик = Счетчик + 1;
|
||||
Ошибка = Ложь;
|
||||
|
||||
Попытка
|
||||
OPI_ПреобразованиеТипов.ПолучитьКоллекциюКлючИЗначение(Запись, ОшибкаКоллекции);
|
||||
Исключение
|
||||
МассивОшибок.Добавить(Новый Структура("row,error", Счетчик, ОшибкаКоллекции));
|
||||
Ошибка = Истина;
|
||||
Продолжить;
|
||||
КонецПопытки;
|
||||
|
||||
Результат = ДобавитьЗапись(Таблица, Запись, Соединение);
|
||||
|
||||
Если Результат["result"] Тогда
|
||||
|
||||
СчетчикУспешных = СчетчикУспешных + 1;
|
||||
|
||||
Иначе
|
||||
|
||||
МассивОшибок.Добавить(Новый Структура("row,error", Счетчик, Результат["error"]));
|
||||
Ошибка = Истина;
|
||||
|
||||
КонецЕсли;
|
||||
|
||||
КонецЦикла;
|
||||
|
||||
Если Транзакция И Не Ошибка Тогда
|
||||
|
||||
Завершение = ВыполнитьЗапросSQL("COMMIT", , , Соединение);
|
||||
СтруктураРезультата.Вставить("commit", Завершение);
|
||||
|
||||
КонецЕсли;
|
||||
|
||||
СтруктураРезультата.Вставить("result", МассивОшибок.Количество() = 0);
|
||||
СтруктураРезультата.Вставить("rows" , СчетчикУспешных);
|
||||
СтруктураРезультата.Вставить("errors", МассивОшибок);
|
||||
|
||||
Возврат СтруктураРезультата;
|
||||
Результат = OPI_ЗапросыSQL.ДобавитьЗаписи(OPI_SQLite, Таблица, МассивДанных, Транзакция, Соединение);
|
||||
Возврат Результат;
|
||||
|
||||
КонецФункции
|
||||
|
||||
@@ -294,19 +211,25 @@
|
||||
, Знач Количество = ""
|
||||
, Знач Соединение = "") Экспорт
|
||||
|
||||
Схема = OPI_ЗапросыSQL.ПустаяСхемаSQL("SELECT");
|
||||
Результат = OPI_ЗапросыSQL.ПолучитьЗаписи(OPI_SQLite, Таблица, Поля, Фильтры, Сортировка, Количество, Соединение);
|
||||
Возврат Результат;
|
||||
|
||||
OPI_ЗапросыSQL.УстановитьИмяТаблицы(Схема, Таблица);
|
||||
OPI_ЗапросыSQL.УстановитьЛимит(Схема, Количество);
|
||||
КонецФункции
|
||||
|
||||
ЗаполнитьПоля(Схема, Поля);
|
||||
ЗаполнитьФильтры(Схема, Фильтры);
|
||||
ЗаполнитьСортировку(Схема, Сортировка);
|
||||
|
||||
Запрос = OPI_ЗапросыSQL.СформироватьТекстSQL(Схема);
|
||||
|
||||
Результат = ВыполнитьЗапросSQL(Запрос, Схема["values"], , Соединение);
|
||||
// Обновить записи
|
||||
// Обновляет значение записей по выбранным критериям
|
||||
//
|
||||
// Параметры:
|
||||
// Таблица - Строка - Имя таблицы - table
|
||||
// СтруктураЗначений - Структура Из КлючИЗначение - Структура значений: Ключ > поле, Значение > значение поля - values
|
||||
// Фильтры - Массив Из Структура - Массив фильтров. См. ПолучитьСтруктуруФильтраЗаписей - filter
|
||||
// Соединение - Строка, Произвольный - Существующее соединение или путь к базе - db
|
||||
//
|
||||
// Возвращаемое значение:
|
||||
// Структура Из КлючИЗначение, Строка - Результат выполнения запроса
|
||||
Функция ОбновитьЗаписи(Знач Таблица, Знач СтруктураЗначений, Знач Фильтры = "", Знач Соединение = "") Экспорт
|
||||
|
||||
Результат = OPI_ЗапросыSQL.ОбновитьЗаписи(OPI_SQLite, Таблица, СтруктураЗначений, Фильтры, Соединение);
|
||||
Возврат Результат;
|
||||
|
||||
КонецФункции
|
||||
@@ -327,20 +250,7 @@
|
||||
// Структура Из КлючИЗначение - Элемент фильтра записей
|
||||
Функция ПолучитьСтруктуруФильтраЗаписей(Знач Пустая = Ложь) Экспорт
|
||||
|
||||
СтруктураФильтра = Новый Структура;
|
||||
|
||||
СтруктураФильтра.Вставить("field", "<имя поля для отбора>");
|
||||
СтруктураФильтра.Вставить("type" , "<тип сравнения>");
|
||||
СтруктураФильтра.Вставить("value", "<значение для сравнения>");
|
||||
СтруктураФильтра.Вставить("union", "<связь со следующим условием: AND, OR и пр.>");
|
||||
СтруктураФильтра.Вставить("raw" , "<истина - значение будет вставлено текстом, как есть, ложь - через параметр>");
|
||||
|
||||
Если Пустая Тогда
|
||||
СтруктураФильтра = OPI_Инструменты.ОчиститьКоллекциюРекурсивно(СтруктураФильтра);
|
||||
КонецЕсли;
|
||||
|
||||
//@skip-check constructor-function-return-section
|
||||
Возврат СтруктураФильтра;
|
||||
Возврат OPI_ЗапросыSQL.ПолучитьСтруктуруФильтраЗаписей(Пустая);
|
||||
|
||||
КонецФункции
|
||||
|
||||
@@ -415,94 +325,4 @@
|
||||
|
||||
КонецФункции
|
||||
|
||||
Функция ЭтоКоннектор(Знач Значение)
|
||||
|
||||
Возврат Строка(ТипЗнч(Значение)) = "AddIn.OPI_SQLite.Main";
|
||||
|
||||
КонецФункции
|
||||
|
||||
Функция ДобавитьЗапись(Знач Таблица, Знач Запись, Знач Соединение)
|
||||
|
||||
МассивПолей = Новый Массив;
|
||||
МассивЗначений = Новый Массив;
|
||||
|
||||
Схема = OPI_ЗапросыSQL.ПустаяСхемаSQL("INSERT");
|
||||
OPI_ЗапросыSQL.УстановитьИмяТаблицы(Схема, Таблица);
|
||||
|
||||
РазделитьКоллекциюДанных(Запись, МассивПолей, МассивЗначений);
|
||||
|
||||
Для Каждого Поле Из МассивПолей Цикл
|
||||
OPI_ЗапросыSQL.ДобавитьПоле(Схема, Поле);
|
||||
КонецЦикла;
|
||||
|
||||
Запрос = OPI_ЗапросыSQL.СформироватьТекстSQL(Схема);
|
||||
|
||||
Результат = ВыполнитьЗапросSQL(Запрос, МассивЗначений, , Соединение);
|
||||
|
||||
Возврат Результат;
|
||||
|
||||
КонецФункции
|
||||
|
||||
Процедура РазделитьКоллекциюДанных(Знач Запись, МассивПолей, МассивЗначений)
|
||||
|
||||
Для Каждого Элемент Из Запись Цикл
|
||||
|
||||
МассивПолей.Добавить(Элемент.Ключ);
|
||||
МассивЗначений.Добавить(Элемент.Значение);
|
||||
|
||||
КонецЦикла;
|
||||
|
||||
КонецПроцедуры
|
||||
|
||||
Процедура ЗаполнитьПоля(Схема, Знач Поля)
|
||||
|
||||
Если Не ЗначениеЗаполнено(Поля) Тогда
|
||||
Поля = "*";
|
||||
КонецЕсли;
|
||||
|
||||
OPI_ПреобразованиеТипов.ПолучитьМассив(Поля);
|
||||
|
||||
Для Каждого Поле Из Поля Цикл
|
||||
OPI_ЗапросыSQL.ДобавитьПоле(Схема, Поле);
|
||||
КонецЦикла;
|
||||
|
||||
КонецПроцедуры
|
||||
|
||||
Процедура ЗаполнитьФильтры(Схема, Знач Фильтры)
|
||||
|
||||
Если Не ЗначениеЗаполнено(Фильтры) Тогда
|
||||
Возврат;
|
||||
КонецЕсли;
|
||||
|
||||
OPI_ПреобразованиеТипов.ПолучитьМассив(Фильтры);
|
||||
|
||||
Для Каждого Фильтр Из Фильтры Цикл
|
||||
|
||||
OPI_ЗапросыSQL.ДобавитьОтбор(Схема
|
||||
, Фильтр["field"]
|
||||
, ?(Фильтр.Свойство("type"), Фильтр["type"], "=")
|
||||
, Фильтр["value"]
|
||||
, ?(Фильтр.Свойство("union"), Фильтр["union"], "AND")
|
||||
, ?(Фильтр.Свойство("raw"), Фильтр["raw"], Ложь));
|
||||
|
||||
КонецЦикла;
|
||||
|
||||
КонецПроцедуры
|
||||
|
||||
Процедура ЗаполнитьСортировку(Знач Схема, Знач Сортировка)
|
||||
|
||||
Если Не ЗначениеЗаполнено(Сортировка) Тогда
|
||||
Возврат;
|
||||
КонецЕсли;
|
||||
|
||||
OPI_ПреобразованиеТипов.ПолучитьКоллекцию(Сортировка);
|
||||
|
||||
Для Каждого Элемент Из Сортировка Цикл
|
||||
|
||||
OPI_ЗапросыSQL.ДобавитьСортировку(Схема, Элемент.Ключ, Элемент.Значение);
|
||||
|
||||
КонецЦикла;
|
||||
|
||||
КонецПроцедуры
|
||||
|
||||
#КонецОбласти
|
||||
|
||||
@@ -1,4 +1,4 @@
|
||||
// OneScript: ./OInt/tools/Modules/OPI_ЗапросыSQL.os
|
||||
// OneScript: ./OInt/tools/Modules/os
|
||||
|
||||
// MIT License
|
||||
|
||||
@@ -42,164 +42,169 @@
|
||||
|
||||
#Область СлужебныйПрограммныйИнтерфейс
|
||||
|
||||
Функция ПустаяСхемаSQL(Знач Действие) Экспорт
|
||||
Функция СоздатьТаблицу(Знач Модуль, Знач Таблица, Знач СтруктураКолонок, Знач Соединение = "") Экспорт
|
||||
|
||||
OPI_ПреобразованиеТипов.ПолучитьСтроку(Действие);
|
||||
ТекстОшибки = "Структура колонок не является валидной структурой ключ-значение";
|
||||
OPI_ПреобразованиеТипов.ПолучитьКоллекциюКлючИЗначение(СтруктураКолонок, ТекстОшибки);
|
||||
|
||||
Действие = вРег(Действие);
|
||||
Схема = ПустаяСхемаSQL("CREATE");
|
||||
|
||||
Если Действие = "SELECT" Тогда
|
||||
УстановитьИмяТаблицы(Схема, Таблица);
|
||||
|
||||
Схема = ПустаяСхемаSelect();
|
||||
Для Каждого Колонка Из СтруктураКолонок Цикл
|
||||
ДобавитьКолонку(Схема, Колонка.Ключ, Колонка.Значение);
|
||||
КонецЦикла;
|
||||
|
||||
ИначеЕсли Действие = "INSERT" Тогда
|
||||
Запрос = СформироватьТекстSQL(Схема);
|
||||
Результат = Модуль.ВыполнитьЗапросSQL(Запрос, , , Соединение);
|
||||
|
||||
Схема = ПустаяСхемаInsert();
|
||||
|
||||
ИначеЕсли Действие = "UPDATE" Тогда
|
||||
|
||||
Схема = ПустаяСхемаUpdate();
|
||||
|
||||
ИначеЕсли Действие = "DELETE" Тогда
|
||||
|
||||
Схема = ПустаяСхемаDelete();
|
||||
|
||||
ИначеЕсли Действие = "CREATE" Тогда
|
||||
|
||||
Схема = ПустаяСхемаCreate();
|
||||
|
||||
Иначе
|
||||
|
||||
Схема = Новый Структура;
|
||||
|
||||
КонецЕсли;
|
||||
|
||||
Возврат Схема;
|
||||
Возврат Результат;
|
||||
|
||||
КонецФункции
|
||||
|
||||
Функция СформироватьТекстSQL(Знач Схема) Экспорт
|
||||
Функция ДобавитьЗаписи(Знач Модуль
|
||||
, Знач Таблица
|
||||
, Знач МассивДанных
|
||||
, Знач Транзакция = Истина
|
||||
, Знач Соединение = "") Экспорт
|
||||
|
||||
ТекстОшибки = "Переданное значение не является валидной схемой SQL запроса";
|
||||
OPI_ПреобразованиеТипов.ПолучитьКоллекциюКлючИЗначение(Схема, ТекстОшибки);
|
||||
OPI_ПреобразованиеТипов.ПолучитьМассив(МассивДанных);
|
||||
OPI_ПреобразованиеТипов.ПолучитьБулево(Транзакция);
|
||||
|
||||
ТипСхемы = "";
|
||||
Соединение = Модуль.ОткрытьСоединение(Соединение);
|
||||
|
||||
Если Не OPI_Инструменты.ПолеКоллекцииСуществует(Схема, "type", ТипСхемы) Тогда
|
||||
ВызватьИсключение ТекстОшибки;
|
||||
Если Не Модуль.ЭтоКоннектор(Соединение) Тогда
|
||||
Возврат Соединение;
|
||||
КонецЕсли;
|
||||
|
||||
ТипСхемы = вРег(ТипСхемы);
|
||||
Если Транзакция Тогда
|
||||
|
||||
Если ТипСхемы = "SELECT" Тогда
|
||||
Начало = Модуль.ВыполнитьЗапросSQL("BEGIN TRANSACTION", , , Соединение);
|
||||
|
||||
ТекстЗапроса = СформироватьТекстSelect(Схема);
|
||||
Если Не Начало["result"] Тогда
|
||||
Возврат Начало;
|
||||
КонецЕсли;
|
||||
|
||||
ИначеЕсли ТипСхемы = "INSERT" Тогда
|
||||
КонецЕсли;
|
||||
|
||||
ТекстЗапроса = СформироватьТекстInsert(Схема);
|
||||
Счетчик = 0;
|
||||
СчетчикУспешных = 0;
|
||||
|
||||
ИначеЕсли ТипСхемы = "UPDATE" Тогда
|
||||
Ошибка = Ложь;
|
||||
МассивОшибок = Новый Массив;
|
||||
ОшибкаКоллекции = "Invalid data";
|
||||
|
||||
ТекстЗапроса = СформироватьТекстUpdate(Схема);
|
||||
СтруктураРезультата = Новый Структура;
|
||||
|
||||
ИначеЕсли ТипСхемы = "DELETE" Тогда
|
||||
Для Каждого Запись Из МассивДанных Цикл
|
||||
|
||||
ТекстЗапроса = СформироватьТекстDelete(Схема);
|
||||
Если Ошибка И Транзакция Тогда
|
||||
|
||||
ИначеЕсли ТипСхемы = "CREATE" Тогда
|
||||
Откат = Модуль.ВыполнитьЗапросSQL("ROLLBACK", , , Соединение);
|
||||
|
||||
ТекстЗапроса = СформироватьТекстCreate(Схема);
|
||||
СчетчикУспешных = 0;
|
||||
СтруктураРезультата.Вставить("rollback", Откат);
|
||||
Прервать;
|
||||
|
||||
КонецЕсли;
|
||||
|
||||
Счетчик = Счетчик + 1;
|
||||
Ошибка = Ложь;
|
||||
|
||||
Попытка
|
||||
OPI_ПреобразованиеТипов.ПолучитьКоллекциюКлючИЗначение(Запись, ОшибкаКоллекции);
|
||||
Исключение
|
||||
МассивОшибок.Добавить(Новый Структура("row,error", Счетчик, ОшибкаКоллекции));
|
||||
Ошибка = Истина;
|
||||
Продолжить;
|
||||
КонецПопытки;
|
||||
|
||||
Результат = ДобавитьЗапись(Модуль, Таблица, Запись, Соединение);
|
||||
|
||||
Если Результат["result"] Тогда
|
||||
|
||||
СчетчикУспешных = СчетчикУспешных + 1;
|
||||
|
||||
Иначе
|
||||
|
||||
ТекстЗапроса = "";
|
||||
МассивОшибок.Добавить(Новый Структура("row,error", Счетчик, Результат["error"]));
|
||||
Ошибка = Истина;
|
||||
|
||||
КонецЕсли;
|
||||
|
||||
Возврат ТекстЗапроса;
|
||||
КонецЦикла;
|
||||
|
||||
Если Транзакция И Не Ошибка Тогда
|
||||
|
||||
Завершение = Модуль.ВыполнитьЗапросSQL("COMMIT", , , Соединение);
|
||||
СтруктураРезультата.Вставить("commit", Завершение);
|
||||
|
||||
КонецЕсли;
|
||||
|
||||
СтруктураРезультата.Вставить("result", МассивОшибок.Количество() = 0);
|
||||
СтруктураРезультата.Вставить("rows" , СчетчикУспешных);
|
||||
СтруктураРезультата.Вставить("errors", МассивОшибок);
|
||||
|
||||
Возврат СтруктураРезультата;
|
||||
|
||||
КонецФункции
|
||||
|
||||
Процедура ДобавитьКолонку(Схема, Знач Имя, Знач Тип) Экспорт
|
||||
Функция ПолучитьЗаписи(Знач Модуль
|
||||
, Знач Таблица
|
||||
, Знач Поля = "*"
|
||||
, Знач Фильтры = ""
|
||||
, Знач Сортировка = ""
|
||||
, Знач Количество = ""
|
||||
, Знач Соединение = "") Экспорт
|
||||
|
||||
OPI_ПреобразованиеТипов.ПолучитьСтроку(Имя);
|
||||
OPI_ПреобразованиеТипов.ПолучитьСтроку(Тип);
|
||||
Схема = ПустаяСхемаSQL("SELECT");
|
||||
|
||||
Если Не Схема["type"] = "CREATE" Тогда
|
||||
Возврат;
|
||||
УстановитьИмяТаблицы(Схема, Таблица);
|
||||
УстановитьНастройкиSelect(Схема, Поля, Фильтры, Сортировка, Количество);
|
||||
|
||||
Запрос = СформироватьТекстSQL(Схема);
|
||||
|
||||
Результат = Модуль.ВыполнитьЗапросSQL(Запрос, Схема["values"], , Соединение);
|
||||
|
||||
Возврат Результат;
|
||||
|
||||
КонецФункции
|
||||
|
||||
Функция ОбновитьЗаписи(Знач Модуль
|
||||
, Знач Таблица
|
||||
, Знач МассивЗначений
|
||||
, Знач Фильтры = ""
|
||||
, Знач Соединение = "") Экспорт
|
||||
|
||||
Схема = ПустаяСхемаSQL("UPDATE");
|
||||
|
||||
УстановитьИмяТаблицы(Схема, Таблица);
|
||||
|
||||
Запрос = СформироватьТекстSQL(Схема);
|
||||
Результат = Модуль.ВыполнитьЗапросSQL(Запрос, Схема["values"], , Соединение);
|
||||
|
||||
Возврат Результат;
|
||||
|
||||
КонецФункции
|
||||
|
||||
Функция ПолучитьСтруктуруФильтраЗаписей(Знач Пустая = Ложь) Экспорт
|
||||
|
||||
СтруктураФильтра = Новый Структура;
|
||||
|
||||
СтруктураФильтра.Вставить("field", "<имя поля для отбора>");
|
||||
СтруктураФильтра.Вставить("type" , "<тип сравнения>");
|
||||
СтруктураФильтра.Вставить("value", "<значение для сравнения>");
|
||||
СтруктураФильтра.Вставить("union", "<связь со следующим условием: AND, OR и пр.>");
|
||||
СтруктураФильтра.Вставить("raw" , "<истина - значение будет вставлено текстом, как есть, ложь - через параметр>");
|
||||
|
||||
Если Пустая Тогда
|
||||
СтруктураФильтра = OPI_Инструменты.ОчиститьКоллекциюРекурсивно(СтруктураФильтра);
|
||||
КонецЕсли;
|
||||
|
||||
СоответствиеКолонки = Новый Соответствие;
|
||||
СоответствиеКолонки.Вставить(Имя, Тип);
|
||||
//@skip-check constructor-function-return-section
|
||||
Возврат СтруктураФильтра;
|
||||
|
||||
Схема["columns"].Добавить(СоответствиеКолонки);
|
||||
|
||||
КонецПроцедуры
|
||||
|
||||
Процедура ДобавитьПоле(Схема, Знач Имя) Экспорт
|
||||
|
||||
OPI_ПреобразованиеТипов.ПолучитьСтроку(Имя);
|
||||
|
||||
Схема["set"].Добавить(Имя);
|
||||
|
||||
КонецПроцедуры
|
||||
|
||||
Процедура ДобавитьОтбор(Схема, Знач Поле, Знач Тип, Знач Значение, Знач Группировка, Знач КакЕсть) Экспорт
|
||||
|
||||
OPI_ПреобразованиеТипов.ПолучитьСтроку(Поле);
|
||||
OPI_ПреобразованиеТипов.ПолучитьСтроку(Тип);
|
||||
OPI_ПреобразованиеТипов.ПолучитьСтроку(Группировка);
|
||||
OPI_ПреобразованиеТипов.ПолучитьБулево(КакЕсть);
|
||||
|
||||
ОсновнаяСтруктура = Новый Структура("field,type,union"
|
||||
, Поле
|
||||
, Тип
|
||||
, Группировка);
|
||||
|
||||
Если КакЕсть Тогда
|
||||
|
||||
ОсновнаяСтруктура.Вставить("value", Строка(Значение));
|
||||
|
||||
Иначе
|
||||
|
||||
Схема["values"].Добавить(Значение);
|
||||
|
||||
ПорядковыйНомер = Схема["values"].Количество();
|
||||
ОсновнаяСтруктура.Вставить("value", "?" + OPI_Инструменты.ЧислоВСтроку(ПорядковыйНомер));
|
||||
|
||||
КонецЕсли;
|
||||
|
||||
|
||||
Схема["filter"].Добавить(ОсновнаяСтруктура);
|
||||
|
||||
КонецПроцедуры
|
||||
|
||||
Процедура ДобавитьСортировку(Схема, Знач Поле, Знач Тип) Экспорт
|
||||
|
||||
OPI_ПреобразованиеТипов.ПолучитьСтроку(Поле);
|
||||
OPI_ПреобразованиеТипов.ПолучитьСтроку(Тип);
|
||||
|
||||
Схема["order"].Добавить(Новый Структура("field,type", Поле, Тип));
|
||||
|
||||
КонецПроцедуры
|
||||
|
||||
|
||||
Процедура УстановитьИмяТаблицы(Схема, Знач Имя) Экспорт
|
||||
|
||||
OPI_ПреобразованиеТипов.ПолучитьСтроку(Имя);
|
||||
|
||||
Схема.Вставить("table", Имя);
|
||||
|
||||
КонецПроцедуры
|
||||
|
||||
Процедура УстановитьЛимит(Схема, Знач Количество) Экспорт
|
||||
|
||||
OPI_ПреобразованиеТипов.ПолучитьЧисло(Количество);
|
||||
|
||||
Схема.Вставить("limit", Количество);
|
||||
|
||||
КонецПроцедуры
|
||||
КонецФункции
|
||||
|
||||
#КонецОбласти
|
||||
|
||||
@@ -240,6 +245,7 @@
|
||||
Схема.Вставить("table" , "");
|
||||
Схема.Вставить("set" , Новый Массив);
|
||||
Схема.Вставить("filter", Новый Массив);
|
||||
Схема.Вставить("values" , Новый Массив);
|
||||
|
||||
Возврат Схема;
|
||||
|
||||
@@ -363,6 +369,87 @@
|
||||
|
||||
#КонецОбласти
|
||||
|
||||
#Область Вспомогательные
|
||||
|
||||
Функция ПустаяСхемаSQL(Знач Действие)
|
||||
|
||||
OPI_ПреобразованиеТипов.ПолучитьСтроку(Действие);
|
||||
|
||||
Действие = вРег(Действие);
|
||||
|
||||
Если Действие = "SELECT" Тогда
|
||||
|
||||
Схема = ПустаяСхемаSelect();
|
||||
|
||||
ИначеЕсли Действие = "INSERT" Тогда
|
||||
|
||||
Схема = ПустаяСхемаInsert();
|
||||
|
||||
ИначеЕсли Действие = "UPDATE" Тогда
|
||||
|
||||
Схема = ПустаяСхемаUpdate();
|
||||
|
||||
ИначеЕсли Действие = "DELETE" Тогда
|
||||
|
||||
Схема = ПустаяСхемаDelete();
|
||||
|
||||
ИначеЕсли Действие = "CREATE" Тогда
|
||||
|
||||
Схема = ПустаяСхемаCreate();
|
||||
|
||||
Иначе
|
||||
|
||||
Схема = Новый Структура;
|
||||
|
||||
КонецЕсли;
|
||||
|
||||
Возврат Схема;
|
||||
|
||||
КонецФункции
|
||||
|
||||
Функция СформироватьТекстSQL(Знач Схема)
|
||||
|
||||
ТекстОшибки = "Переданное значение не является валидной схемой SQL запроса";
|
||||
OPI_ПреобразованиеТипов.ПолучитьКоллекциюКлючИЗначение(Схема, ТекстОшибки);
|
||||
|
||||
ТипСхемы = "";
|
||||
|
||||
Если Не OPI_Инструменты.ПолеКоллекцииСуществует(Схема, "type", ТипСхемы) Тогда
|
||||
ВызватьИсключение ТекстОшибки;
|
||||
КонецЕсли;
|
||||
|
||||
ТипСхемы = вРег(ТипСхемы);
|
||||
|
||||
Если ТипСхемы = "SELECT" Тогда
|
||||
|
||||
ТекстЗапроса = СформироватьТекстSelect(Схема);
|
||||
|
||||
ИначеЕсли ТипСхемы = "INSERT" Тогда
|
||||
|
||||
ТекстЗапроса = СформироватьТекстInsert(Схема);
|
||||
|
||||
ИначеЕсли ТипСхемы = "UPDATE" Тогда
|
||||
|
||||
ТекстЗапроса = СформироватьТекстUpdate(Схема);
|
||||
|
||||
ИначеЕсли ТипСхемы = "DELETE" Тогда
|
||||
|
||||
ТекстЗапроса = СформироватьТекстDelete(Схема);
|
||||
|
||||
ИначеЕсли ТипСхемы = "CREATE" Тогда
|
||||
|
||||
ТекстЗапроса = СформироватьТекстCreate(Схема);
|
||||
|
||||
Иначе
|
||||
|
||||
ТекстЗапроса = "";
|
||||
|
||||
КонецЕсли;
|
||||
|
||||
Возврат ТекстЗапроса;
|
||||
|
||||
КонецФункции
|
||||
|
||||
Функция СформироватьТекстНастроекSelect(Знач Фильтры, Знач Сортировка, Знач Количество)
|
||||
|
||||
ШаблонБлока = "%1
|
||||
@@ -454,6 +541,90 @@
|
||||
|
||||
КонецФункции
|
||||
|
||||
Функция ДобавитьЗапись(Знач Модуль, Знач Таблица, Знач Запись, Знач Соединение)
|
||||
|
||||
МассивПолей = Новый Массив;
|
||||
МассивЗначений = Новый Массив;
|
||||
|
||||
Схема = ПустаяСхемаSQL("INSERT");
|
||||
УстановитьИмяТаблицы(Схема, Таблица);
|
||||
|
||||
РазделитьКоллекциюДанных(Запись, МассивПолей, МассивЗначений);
|
||||
|
||||
Для Каждого Поле Из МассивПолей Цикл
|
||||
ДобавитьПоле(Схема, Поле);
|
||||
КонецЦикла;
|
||||
|
||||
Запрос = СформироватьТекстSQL(Схема);
|
||||
|
||||
Результат = Модуль.ВыполнитьЗапросSQL(Запрос, МассивЗначений, , Соединение);
|
||||
|
||||
Возврат Результат;
|
||||
|
||||
КонецФункции
|
||||
|
||||
Процедура РазделитьКоллекциюДанных(Знач Запись, МассивПолей, МассивЗначений)
|
||||
|
||||
Для Каждого Элемент Из Запись Цикл
|
||||
|
||||
МассивПолей.Добавить(Элемент.Ключ);
|
||||
МассивЗначений.Добавить(Элемент.Значение);
|
||||
|
||||
КонецЦикла;
|
||||
|
||||
КонецПроцедуры
|
||||
|
||||
Процедура ЗаполнитьПоля(Схема, Знач Поля)
|
||||
|
||||
Если Не ЗначениеЗаполнено(Поля) Тогда
|
||||
Поля = "*";
|
||||
КонецЕсли;
|
||||
|
||||
OPI_ПреобразованиеТипов.ПолучитьМассив(Поля);
|
||||
|
||||
Для Каждого Поле Из Поля Цикл
|
||||
ДобавитьПоле(Схема, Поле);
|
||||
КонецЦикла;
|
||||
|
||||
КонецПроцедуры
|
||||
|
||||
Процедура ЗаполнитьФильтры(Схема, Знач Фильтры)
|
||||
|
||||
Если Не ЗначениеЗаполнено(Фильтры) Тогда
|
||||
Возврат;
|
||||
КонецЕсли;
|
||||
|
||||
OPI_ПреобразованиеТипов.ПолучитьМассив(Фильтры);
|
||||
|
||||
Для Каждого Фильтр Из Фильтры Цикл
|
||||
|
||||
ДобавитьОтбор(Схема
|
||||
, Фильтр["field"]
|
||||
, ?(Фильтр.Свойство("type"), Фильтр["type"], "=")
|
||||
, Фильтр["value"]
|
||||
, ?(Фильтр.Свойство("union"), Фильтр["union"], "AND")
|
||||
, ?(Фильтр.Свойство("raw"), Фильтр["raw"], Ложь));
|
||||
|
||||
КонецЦикла;
|
||||
|
||||
КонецПроцедуры
|
||||
|
||||
Процедура ЗаполнитьСортировку(Знач Схема, Знач Сортировка)
|
||||
|
||||
Если Не ЗначениеЗаполнено(Сортировка) Тогда
|
||||
Возврат;
|
||||
КонецЕсли;
|
||||
|
||||
OPI_ПреобразованиеТипов.ПолучитьКоллекцию(Сортировка);
|
||||
|
||||
Для Каждого Элемент Из Сортировка Цикл
|
||||
|
||||
ДобавитьСортировку(Схема, Элемент.Ключ, Элемент.Значение);
|
||||
|
||||
КонецЦикла;
|
||||
|
||||
КонецПроцедуры
|
||||
|
||||
Процедура ПроверитьОбязательныеПоляСхемы(Схема, Знач Поля)
|
||||
|
||||
МассивОбязательныхПолей = СтрРазделить(Поля, ",");
|
||||
@@ -465,4 +636,95 @@
|
||||
|
||||
КонецПроцедуры
|
||||
|
||||
Процедура ДобавитьКолонку(Схема, Знач Имя, Знач Тип) Экспорт
|
||||
|
||||
OPI_ПреобразованиеТипов.ПолучитьСтроку(Имя);
|
||||
OPI_ПреобразованиеТипов.ПолучитьСтроку(Тип);
|
||||
|
||||
Если Не Схема["type"] = "CREATE" Тогда
|
||||
Возврат;
|
||||
КонецЕсли;
|
||||
|
||||
СоответствиеКолонки = Новый Соответствие;
|
||||
СоответствиеКолонки.Вставить(Имя, Тип);
|
||||
|
||||
Схема["columns"].Добавить(СоответствиеКолонки);
|
||||
|
||||
КонецПроцедуры
|
||||
|
||||
Процедура ДобавитьПоле(Схема, Знач Имя) Экспорт
|
||||
|
||||
OPI_ПреобразованиеТипов.ПолучитьСтроку(Имя);
|
||||
|
||||
Схема["set"].Добавить(Имя);
|
||||
|
||||
КонецПроцедуры
|
||||
|
||||
Процедура ДобавитьОтбор(Схема, Знач Поле, Знач Тип, Знач Значение, Знач Группировка, Знач КакЕсть)
|
||||
|
||||
OPI_ПреобразованиеТипов.ПолучитьСтроку(Поле);
|
||||
OPI_ПреобразованиеТипов.ПолучитьСтроку(Тип);
|
||||
OPI_ПреобразованиеТипов.ПолучитьСтроку(Группировка);
|
||||
OPI_ПреобразованиеТипов.ПолучитьБулево(КакЕсть);
|
||||
|
||||
ОсновнаяСтруктура = Новый Структура("field,type,union"
|
||||
, Поле
|
||||
, Тип
|
||||
, Группировка);
|
||||
|
||||
Если КакЕсть Тогда
|
||||
|
||||
ОсновнаяСтруктура.Вставить("value", Строка(Значение));
|
||||
|
||||
Иначе
|
||||
|
||||
Схема["values"].Добавить(Значение);
|
||||
|
||||
ПорядковыйНомер = Схема["values"].Количество();
|
||||
ОсновнаяСтруктура.Вставить("value", "?" + OPI_Инструменты.ЧислоВСтроку(ПорядковыйНомер));
|
||||
|
||||
КонецЕсли;
|
||||
|
||||
|
||||
Схема["filter"].Добавить(ОсновнаяСтруктура);
|
||||
|
||||
КонецПроцедуры
|
||||
|
||||
Процедура ДобавитьСортировку(Схема, Знач Поле, Знач Тип)
|
||||
|
||||
OPI_ПреобразованиеТипов.ПолучитьСтроку(Поле);
|
||||
OPI_ПреобразованиеТипов.ПолучитьСтроку(Тип);
|
||||
|
||||
Схема["order"].Добавить(Новый Структура("field,type", Поле, Тип));
|
||||
|
||||
КонецПроцедуры
|
||||
|
||||
Процедура УстановитьИмяТаблицы(Схема, Знач Имя)
|
||||
|
||||
OPI_ПреобразованиеТипов.ПолучитьСтроку(Имя);
|
||||
|
||||
Схема.Вставить("table", Имя);
|
||||
|
||||
КонецПроцедуры
|
||||
|
||||
Процедура УстановитьЛимит(Схема, Знач Количество)
|
||||
|
||||
OPI_ПреобразованиеТипов.ПолучитьЧисло(Количество);
|
||||
|
||||
Схема.Вставить("limit", Количество);
|
||||
|
||||
КонецПроцедуры
|
||||
|
||||
Процедура УстановитьНастройкиSelect(Схема, Знач Поля, Знач Фильтры, Знач Сортировка, Знач Количество)
|
||||
|
||||
УстановитьЛимит(Схема, Количество);
|
||||
|
||||
ЗаполнитьПоля(Схема, Поля);
|
||||
ЗаполнитьФильтры(Схема, Фильтры);
|
||||
ЗаполнитьСортировку(Схема, Сортировка);
|
||||
|
||||
КонецПроцедуры
|
||||
|
||||
#КонецОбласти
|
||||
|
||||
#КонецОбласти
|
||||
|
||||
@@ -1,4 +1,4 @@
|
||||
// OneScript: ./OInt/tools/Modules/internal/Modules/OPI_Инструменты.os
|
||||
// OneScript: ./OInt/tools/Modules/internal/Modules/OPI_Инструменты.os
|
||||
|
||||
// MIT License
|
||||
|
||||
|
||||
@@ -16250,13 +16250,10 @@
|
||||
СтруктураКолонок.Вставить("created_at", "DATETIME");
|
||||
СтруктураКолонок.Вставить("data" , "BLOB");
|
||||
|
||||
Результат = OPI_SQLite.СоздатьТаблицу(Таблица, СтруктураКолонок, , База);
|
||||
Результат = OPI_SQLite.СоздатьТаблицу(Таблица, СтруктураКолонок, База);
|
||||
|
||||
// END
|
||||
|
||||
Текст = OPI_SQLite.СоздатьТаблицу(Таблица, СтруктураКолонок, Истина, База);
|
||||
OPI_ПолучениеДанныхТестов.ЗаписатьЛог(Текст, "СоздатьТаблицу (запрос)", "SQLite");
|
||||
|
||||
OPI_ПолучениеДанныхТестов.ЗаписатьЛог(Результат, "СоздатьТаблицу", "SQLite");
|
||||
OPI_ПолучениеДанныхТестов.Проверка_SQLiteУспех(Результат);
|
||||
|
||||
@@ -16264,7 +16261,7 @@
|
||||
СоответствиеКолонок.Вставить("id" , "INTEGER PRIMARY KEY");
|
||||
СоответствиеКолонок.Вставить("[Непонятная колонка]", "TEXT");
|
||||
|
||||
Результат = OPI_SQLite.СоздатьТаблицу("test1", СоответствиеКолонок, , База);
|
||||
Результат = OPI_SQLite.СоздатьТаблицу("test1", СоответствиеКолонок, База);
|
||||
|
||||
OPI_ПолучениеДанныхТестов.ЗаписатьЛог(Результат, "СоздатьТаблицу (непонятная колонка)", "SQLite");
|
||||
OPI_ПолучениеДанныхТестов.Проверка_SQLiteУспех(Результат);
|
||||
|
||||
Reference in New Issue
Block a user