1c/OpenIntegrations
1
0
Fork 0
mirror of https://github.com/Bayselonarrend/OpenIntegrations.git synced 2026-06-20 09:19:27 +02:00
Code Issues Releases Activity

Main build (Jenkins)

Browse Source
This commit is contained in:
Vitaly the Alpaca (bot)
2025-02-15 13:38:30 +03:00
parent 908c6ae835
commit 3ff3d8b30b
52 changed files with 7126 additions and 6850 deletions
Download Patch File Download Diff File Expand all files Collapse all files
ci/clitesten
Vendored
+3 -3
View File
@@ -242,7 +242,7 @@ def test_airtable(){
}
catchError(buildResult: 'FAILURE', stageResult: 'FAILURE') {
powershell encoding: 'UTF-8', script:'./oint.exe airtable DeletePosts --token "test" --base "test" --table "test" --records "test" --debug --test '
powershell encoding: 'UTF-8', script:'./oint.exe airtable DeleteRecords --token "test" --base "test" --table "test" --records "test" --debug --test '
}
catchError(buildResult: 'FAILURE', stageResult: 'FAILURE') {
@@ -1802,7 +1802,7 @@ def test_postgres(){
}
catchError(buildResult: 'FAILURE', stageResult: 'FAILURE') {
powershell encoding: 'UTF-8', script:'./oint.exe postgres DeletePosts --table "test" --filter "test" --dbc "test" --debug --test '
powershell encoding: 'UTF-8', script:'./oint.exe postgres DeleteRecords --table "test" --filter "test" --dbc "test" --debug --test '
}
catchError(buildResult: 'FAILURE', stageResult: 'FAILURE') {
@@ -2128,7 +2128,7 @@ def test_sqlite(){
}
catchError(buildResult: 'FAILURE', stageResult: 'FAILURE') {
powershell encoding: 'UTF-8', script:'./oint.exe sqlite DeletePosts --table "test" --filter "test" --db "test" --debug --test '
powershell encoding: 'UTF-8', script:'./oint.exe sqlite DeleteRecords --table "test" --filter "test" --db "test" --debug --test '
}
catchError(buildResult: 'FAILURE', stageResult: 'FAILURE') {
docs/en/data/Airtable/DeleteRecords.json
Vendored
+6
View File
@@ -0,0 +1,6 @@
{
"Token": "patNn4BXW66Yx3pdj.5b93c53cab554a8387de02d...",
"Base": "app8gZU8Lekaiu67B",
"Table": "tbldAsVDqopWCC1JQ",
"Record": "recPGu3clCnI0MtlJ"
}
docs/en/data/PostgreSQL/DeleteDatabase.json
Vendored
+4
View File
@@ -0,0 +1,4 @@
{
"Address": "93.125.42.204",
"Password": "12we..."
}
docs/en/data/PostgreSQL/DeleteRecords.json
Vendored
+4
View File
@@ -0,0 +1,4 @@
{
"Address": "93.125.42.204",
"Password": "12we..."
}
docs/en/data/SQLite/DeleteRecords.json
Vendored
+3
View File
@@ -0,0 +1,3 @@
{
"Base": "C:\\Users\\Administrator\\AppData\\Local\\Temp\\v8_80B2_2a.sqlite"
}
docs/en/examples/Airtable/DeleteRecords.txt
Vendored
+6
View File
@@ -0,0 +1,6 @@
Token = "patNn4BXW66Yx3pdj.5b93c53cab554a8387de02d...";
Base = "app8gZU8Lekaiu67B";
Table = "tbldAsVDqopWCC1JQ";
Record = "recPGu3clCnI0MtlJ";
Result = OPI_Airtable.DeleteRecords(Token, Base, Table, Record);
docs/en/examples/PostgreSQL/DeleteDatabase.txt
Vendored
+14
View File
@@ -0,0 +1,14 @@
Address = "93.125.42.204";
Login = "bayselonarrend";
Password = "12we...";
Base = "postgres";
// When using the connection string, a new connection is initialised,
// which will be closed after the function is executed.
// If several operations are performed, it is desirable to use one connection,
// previously created by the CreateConnection function()
ConnectionString = OPI_PostgreSQL.GenerateConnectionString(Address, Base, Login, Password);
Base = "testbase1";
Result = OPI_PostgreSQL.DeleteDatabase(Base, ConnectionString);
docs/en/examples/PostgreSQL/DeleteRecords.txt
Vendored
+33
View File
@@ -0,0 +1,33 @@
Address = "93.125.42.204";
Login = "bayselonarrend";
Password = "12we...";
Base = "test_data";
// When using the connection string, a new connection is initialised,
// which will be closed after the function is executed.
// If several operations are performed, it is desirable to use one connection,
// previously created by the CreateConnection function()
ConnectionString = OPI_PostgreSQL.GenerateConnectionString(Address, Base, Login, Password);
Table = "test_data";
Filters = New Array;
FilterStructure = New Structure;
FilterStructure.Insert("field", "gender");
FilterStructure.Insert("type" , "=");
FilterStructure.Insert("value", New Structure("VARCHAR", "Male"));
FilterStructure.Insert("raw" , False);
FilterStructure.Insert("union", "AND");
Filters.Add(FilterStructure);
FilterStructure = New Structure;
FilterStructure.Insert("field", "ip_address");
FilterStructure.Insert("type" , "=");
FilterStructure.Insert("value", New Structure("VARCHAR", "127.0.0.1"));
FilterStructure.Insert("raw" , False);
Result = OPI_PostgreSQL.DeleteRecords(Table, Filters, ConnectionString);
docs/en/examples/PostgreSQL/DisableAllDatabaseConnections.txt
Vendored
+1 -1
View File
@@ -1,4 +1,4 @@
Address = "93.125.42.204";
Address = "93.125.42.204";
Login = "bayselonarrend";
Password = "12we...";
Base = "testbase1";
docs/en/examples/PostgreSQL/UpdateRecords.txt
Vendored
+5 -8
View File
@@ -1,7 +1,7 @@
Address = "93.125.42.204";
Login = "bayselonarrend";
Password = "12we...";
Base = "testbase1";
Base = "test_data";
// When using the connection string, a new connection is initialised,
// which will be closed after the function is executed.
@@ -9,21 +9,18 @@
// previously created by the CreateConnection function()
ConnectionString = OPI_PostgreSQL.GenerateConnectionString(Address, Base, Login, Password);
Table = "testtable";
Table = "test_data";
FieldsStructure = New Structure;
FieldsStructure.Insert("bool_field" , New Structure("BOOL" , False));
FieldsStructure.Insert("oldchar_field" , New Structure("OLDCHAR" , 2));
FieldsStructure.Insert("smallint_field" , New Structure("SMALLINT" , 10));
FieldsStructure.Insert("smallserial_field", New Structure("SMALLSERIAL" , 10));
FieldsStructure.Insert("ip_address", New Structure("VARCHAR", "127.0.0.1"));
Filters = New Array;
FilterStructure = New Structure;
FilterStructure.Insert("field", "oid_field");
FilterStructure.Insert("field", "gender");
FilterStructure.Insert("type" , "=");
FilterStructure.Insert("value", New Structure("OID", 24576));
FilterStructure.Insert("value", New Structure("VARCHAR", "Male"));
FilterStructure.Insert("raw" , False);
Filters.Add(FilterStructure);
docs/en/examples/SQLite/DeleteRecords.txt
Vendored
+16
View File
@@ -0,0 +1,16 @@
Base = "C:\Users\Administrator\AppData\Local\Temp\v8_80B2_2a.sqlite";
Table = "test";
Filters = New Array;
FilterStructure = New Structure;
FilterStructure.Insert("field", "name");
FilterStructure.Insert("type" , "=");
FilterStructure.Insert("value", "Vitaly A.");
FilterStructure.Insert("union", "AND");
FilterStructure.Insert("raw" , False);
Filters.Add(FilterStructure);
Result = OPI_SQLite.DeleteRecords(Table, FilterStructure, Base);
docs/en/md/Airtable/Record-management/Delete-posts.mdx
Vendored
-73
View File
@@ -1,73 +0,0 @@
---
sidebar_position: 4
---
import Tabs from '@theme/Tabs';
import TabItem from '@theme/TabItem';
# Delete records
Deletes one or an array of records by identifiers
`Function DeletePosts(Val Token, Val Base, Val Table, Val Records) Export`
| Parameter | CLI option | Type | Required | Description |
|-|-|-|-|-|
| Token | --token | String | ✔ | Token |
| Base | --base | String | ✔ | Database identifier |
| Table | --table | String | ✔ | Table identifier |
| Records | --records | String, Array of String | ✔ | Identifier or array of record identifiers |
Returns: Map Of KeyAndValue - serialized JSON response from Airtable
<br/>
```bsl title="1C:Enterprise/OneScript code example"
Token = "patNn4BXW66Yx3pdj.5b93c53cab554a8387de02d...";
Base = "app8gZU8Lekaiu67B";
Table = "tbldAsVDqopWCC1JQ";
Record = "recPGu3clCnI0MtlJ";
Result = OPI_Airtable.DeletePosts(Token, Base, Table, Record);
```
<Tabs>
<TabItem value="bash" label="Bash" default>
```bash
oint airtable DeletePosts \
--token "***" \
--base "app3YffmF20K2SlAN" \
--table "tblV77xKxUuG7dIZs" \
--records "recG96IW5YipjWji8"
```
</TabItem>
<TabItem value="bat" label="CMD/Bat" default>
```batch
oint airtable DeletePosts ^
--token "***" ^
--base "app3YffmF20K2SlAN" ^
--table "tblV77xKxUuG7dIZs" ^
--records "recG96IW5YipjWji8"
```
</TabItem>
</Tabs>
```json title="Result"
{
"records": [
{
"deleted": true,
"id": "recMPMkPT6RzcSyqt"
}
]
}
```
docs/en/md/Airtable/Record-management/Delete-records.mdx
Vendored
+42
View File
@@ -0,0 +1,42 @@
---
sidebar_position: 4
---
import Tabs from '@theme/Tabs';
import TabItem from '@theme/TabItem';
# Delete records
Deletes one or an array of records by identifiers
`Function DeleteRecords(Val Token, Val Base, Val Table, Val Records) Export`
| Parameter | CLI option | Type | Required | Description |
|-|-|-|-|-|
| Token | --token | String | &#x2714; | Token |
| Base | --base | String | &#x2714; | Database identifier |
| Table | --table | String | &#x2714; | Table identifier |
| Records | --records | String, Array of String | &#x2714; | Identifier or array of record identifiers |
Returns: Map Of KeyAndValue - serialized JSON response from Airtable
<br/>
```bsl title="1C:Enterprise/OneScript code example"
Token = "patNn4BXW66Yx3pdj.5b93c53cab554a8387de02d...";
Base = "app8gZU8Lekaiu67B";
Table = "tbldAsVDqopWCC1JQ";
Record = "recPGu3clCnI0MtlJ";
Result = OPI_Airtable.DeleteRecords(Token, Base, Table, Record);
```
docs/en/md/PostgreSQL/Orm/Drop-database.mdx → docs/en/md/PostgreSQL/Orm/Delete-database.mdx
Vendored
View File
docs/en/md/PostgreSQL/Orm/Delete-posts.mdx
Vendored
-36
View File
@@ -1,36 +0,0 @@
---
sidebar_position: 11
---
import Tabs from '@theme/Tabs';
import TabItem from '@theme/TabItem';
# Delete records
Deletes records from the table
`Function DeletePosts(Val Table, Val Filters = "", Val Connection = "") Export`
| Parameter | CLI option | Type | Required | Description |
|-|-|-|-|-|
| Table | --table | String | &#x2714; | Table name |
| Filters | --filter | Array of Structure | &#x2716; | Filters array. See GetRecordsFilterStrucutre |
| Connection | --dbc | String, Arbitrary | &#x2716; | Connection or connection string |
Returns: Structure Of KeyAndValue, String - Result of query execution
<br/>
```bsl title="1C:Enterprise/OneScript code example"
```
docs/en/md/PostgreSQL/Orm/Delete-records.mdx
Vendored
+68
View File
@@ -0,0 +1,68 @@
---
sidebar_position: 11
---
import Tabs from '@theme/Tabs';
import TabItem from '@theme/TabItem';
# Delete records
Deletes records from the table
`Function DeleteRecords(Val Table, Val Filters = "", Val Connection = "") Export`
| Parameter | CLI option | Type | Required | Description |
|-|-|-|-|-|
| Table | --table | String | &#x2714; | Table name |
| Filters | --filter | Array of Structure | &#x2716; | Filters array. See GetRecordsFilterStrucutre |
| Connection | --dbc | String, Arbitrary | &#x2716; | Connection or connection string |
Returns: Structure Of KeyAndValue, String - Result of query execution
<br/>
```bsl title="1C:Enterprise/OneScript code example"
Address = "93.125.42.204";
Login = "bayselonarrend";
Password = "12we...";
Base = "test_data";
// When using the connection string, a new connection is initialised,
// which will be closed after the function is executed.
// If several operations are performed, it is desirable to use one connection,
// previously created by the CreateConnection function()
ConnectionString = OPI_PostgreSQL.GenerateConnectionString(Address, Base, Login, Password);
Table = "test_data";
Filters = New Array;
FilterStructure = New Structure;
FilterStructure.Insert("field", "gender");
FilterStructure.Insert("type" , "=");
FilterStructure.Insert("value", New Structure("VARCHAR", "Male"));
FilterStructure.Insert("raw" , False);
FilterStructure.Insert("union", "AND");
Filters.Add(FilterStructure);
FilterStructure = New Structure;
FilterStructure.Insert("field", "ip_address");
FilterStructure.Insert("type" , "=");
FilterStructure.Insert("value", New Structure("VARCHAR", "127.0.0.1"));
FilterStructure.Insert("raw" , False);
Result = OPI_PostgreSQL.DeleteRecords(Table, Filters, ConnectionString);
```
docs/en/md/PostgreSQL/Orm/Disable-all-database-connections.mdx
Vendored
+1 -1
View File
@@ -26,7 +26,7 @@ import TabItem from '@theme/TabItem';
```bsl title="1C:Enterprise/OneScript code example"
Address = "93.125.42.204";
Address = "93.125.42.204";
Login = "bayselonarrend";
Password = "12we...";
Base = "testbase1";
docs/en/md/PostgreSQL/Orm/Update-records.mdx
Vendored
+5 -8
View File
@@ -31,7 +31,7 @@ import TabItem from '@theme/TabItem';
Address = "93.125.42.204";
Login = "bayselonarrend";
Password = "12we...";
Base = "testbase1";
Base = "test_data";
// When using the connection string, a new connection is initialised,
// which will be closed after the function is executed.
@@ -39,21 +39,18 @@ import TabItem from '@theme/TabItem';
// previously created by the CreateConnection function()
ConnectionString = OPI_PostgreSQL.GenerateConnectionString(Address, Base, Login, Password);
Table = "testtable";
Table = "test_data";
FieldsStructure = New Structure;
FieldsStructure.Insert("bool_field" , New Structure("BOOL" , False));
FieldsStructure.Insert("oldchar_field" , New Structure("OLDCHAR" , 2));
FieldsStructure.Insert("smallint_field" , New Structure("SMALLINT" , 10));
FieldsStructure.Insert("smallserial_field", New Structure("SMALLSERIAL" , 10));
FieldsStructure.Insert("ip_address", New Structure("VARCHAR", "127.0.0.1"));
Filters = New Array;
FilterStructure = New Structure;
FilterStructure.Insert("field", "oid_field");
FilterStructure.Insert("field", "gender");
FilterStructure.Insert("type" , "=");
FilterStructure.Insert("value", New Structure("OID", 24576));
FilterStructure.Insert("value", New Structure("VARCHAR", "Male"));
FilterStructure.Insert("raw" , False);
Filters.Add(FilterStructure);
docs/en/md/SQLite/Orm/Delete-posts.mdx
Vendored
-79
View File
@@ -1,79 +0,0 @@
---
sidebar_position: 6
---
import Tabs from '@theme/Tabs';
import TabItem from '@theme/TabItem';
# Delete records
Deletes records from the table
`Function DeletePosts(Val Table, Val Filters = "", Val Connection = "") Export`
| Parameter | CLI option | Type | Required | Description |
|-|-|-|-|-|
| Table | --table | String | &#x2714; | Table name |
| Filters | --filter | Array of Structure | &#x2716; | Filters array. See GetRecordsFilterStrucutre |
| Connection | --db | String, Arbitrary | &#x2716; | Existing connection or database path |
Returns: Map Of KeyAndValue - Result of query execution
<br/>
```bsl title="1C:Enterprise/OneScript code example"
Base = "C:\Users\Administrator\AppData\Local\Temp\v8_80B2_2a.sqlite";
Table = "test";
Filters = New Array;
FilterStructure = New Structure;
FilterStructure.Insert("field", "name");
FilterStructure.Insert("type" , "=");
FilterStructure.Insert("value", "Vitaly A.");
FilterStructure.Insert("union", "AND");
FilterStructure.Insert("raw" , False);
Filters.Add(FilterStructure);
Result = OPI_SQLite.DeletePosts(Table, FilterStructure, Base);
```
<Tabs>
<TabItem value="bash" label="Bash" default>
```bash
# JSON data can also be passed as a path to a .json file
oint sqlite DeletePosts \
--table "test" \
--filter "{'field':'name','type':'=','value':'Vitaly A.','union':'AND','raw':false}" \
--db "C:\Users\Administrator\AppData\Local\Temp\cfyaxf0knp1.sqlite"
```
</TabItem>
<TabItem value="bat" label="CMD/Bat" default>
```batch
:: JSON data can also be passed as a path to a .json file
oint sqlite DeletePosts ^
--table "test" ^
--filter "{'field':'name','type':'=','value':'Vitaly A.','union':'AND','raw':false}" ^
--db "C:\Users\Administrator\AppData\Local\Temp\cfyaxf0knp1.sqlite"
```
</TabItem>
</Tabs>
```json title="Result"
{
"result": true
}
```
docs/en/md/SQLite/Orm/Delete-records.mdx
Vendored
+51
View File
@@ -0,0 +1,51 @@
---
sidebar_position: 6
---
import Tabs from '@theme/Tabs';
import TabItem from '@theme/TabItem';
# Delete records
Deletes records from the table
`Function DeleteRecords(Val Table, Val Filters = "", Val Connection = "") Export`
| Parameter | CLI option | Type | Required | Description |
|-|-|-|-|-|
| Table | --table | String | &#x2714; | Table name |
| Filters | --filter | Array of Structure | &#x2716; | Filters array. See GetRecordsFilterStrucutre |
| Connection | --db | String, Arbitrary | &#x2716; | Existing connection or database path |
Returns: Map Of KeyAndValue - Result of query execution
<br/>
```bsl title="1C:Enterprise/OneScript code example"
Base = "C:\Users\Administrator\AppData\Local\Temp\v8_80B2_2a.sqlite";
Table = "test";
Filters = New Array;
FilterStructure = New Structure;
FilterStructure.Insert("field", "name");
FilterStructure.Insert("type" , "=");
FilterStructure.Insert("value", "Vitaly A.");
FilterStructure.Insert("union", "AND");
FilterStructure.Insert("raw" , False);
Filters.Add(FilterStructure);
Result = OPI_SQLite.DeleteRecords(Table, FilterStructure, Base);
```
docs/ru/data/PostgreSQL/УдалитьЗаписи.json
Vendored
+4
View File
@@ -0,0 +1,4 @@
{
"Адрес": "93.125.42.204",
"Пароль": "12we..."
}
docs/ru/examples/PostgreSQL/ОбновитьЗаписи.txt
Vendored
+5 -8
View File
@@ -1,7 +1,7 @@
Адрес = "93.125.42.204";
Логин = "bayselonarrend";
Пароль = "12we...";
База = "testbase1";
База = "test_data";
// При использовании строки подключения инициализируется новое соединение,
// которое будет закрыто после выполнения функции.
@@ -9,21 +9,18 @@
// заранее созданное функцией ОткрытьСоединение()
СтрокаПодключения = OPI_PostgreSQL.СформироватьСтрокуПодключения(Адрес, База, Логин, Пароль);
Таблица = "testtable";
Таблица = "test_data";
СтруктураПолей = Новый Структура;
СтруктураПолей.Вставить("bool_field" , Новый Структура("BOOL" , Ложь));
СтруктураПолей.Вставить("oldchar_field" , Новый Структура("OLDCHAR" , 2));
СтруктураПолей.Вставить("smallint_field" , Новый Структура("SMALLINT" , 10));
СтруктураПолей.Вставить("smallserial_field", Новый Структура("SMALLSERIAL" , 10));
СтруктураПолей.Вставить("ip_address", Новый Структура("VARCHAR", "127.0.0.1"));
Фильтры = Новый Массив;
СтруктураФильтра = Новый Структура;
СтруктураФильтра.Вставить("field", "oid_field");
СтруктураФильтра.Вставить("field", "gender");
СтруктураФильтра.Вставить("type" , "=");
СтруктураФильтра.Вставить("value", Новый Структура("OID", 24576));
СтруктураФильтра.Вставить("value", Новый Структура("VARCHAR", "Male"));
СтруктураФильтра.Вставить("raw" , Ложь);
Фильтры.Добавить(СтруктураФильтра);
docs/ru/examples/PostgreSQL/ОтключитьВсеСоединенияБазыДанных.txt
Vendored
+1 -1
View File
@@ -1,4 +1,4 @@
Адрес = "93.125.42.204";
Адрес = "93.125.42.204";
Логин = "bayselonarrend";
Пароль = "12we...";
База = "testbase1";
docs/ru/examples/PostgreSQL/УдалитьЗаписи.txt
Vendored
+33
View File
@@ -0,0 +1,33 @@
Адрес = "93.125.42.204";
Логин = "bayselonarrend";
Пароль = "12we...";
База = "test_data";
// При использовании строки подключения инициализируется новое соединение,
// которое будет закрыто после выполнения функции.
// В случае выполнения нескольких операций желательно использовать одно соединение,
// заранее созданное функцией ОткрытьСоединение()
СтрокаПодключения = OPI_PostgreSQL.СформироватьСтрокуПодключения(Адрес, База, Логин, Пароль);
Таблица = "test_data";
Фильтры = Новый Массив;
СтруктураФильтра = Новый Структура;
СтруктураФильтра.Вставить("field", "gender");
СтруктураФильтра.Вставить("type" , "=");
СтруктураФильтра.Вставить("value", Новый Структура("VARCHAR", "Male"));
СтруктураФильтра.Вставить("raw" , Ложь);
СтруктураФильтра.Вставить("union", "AND");
Фильтры.Добавить(СтруктураФильтра);
СтруктураФильтра = Новый Структура;
СтруктураФильтра.Вставить("field", "ip_address");
СтруктураФильтра.Вставить("type" , "=");
СтруктураФильтра.Вставить("value", Новый Структура("VARCHAR", "127.0.0.1"));
СтруктураФильтра.Вставить("raw" , Ложь);
Результат = OPI_PostgreSQL.УдалитьЗаписи(Таблица, Фильтры, СтрокаПодключения);
docs/ru/md/Airtable/Record-management/Delete-posts.mdx → docs/ru/md/Airtable/Record-management/Delete-records.mdx
Vendored
View File
docs/ru/md/PostgreSQL/Orm/Drop-database.mdx → docs/ru/md/PostgreSQL/Orm/Delete-database.mdx
Vendored
View File
docs/ru/md/PostgreSQL/Orm/Delete-posts.mdx
Vendored
-36
View File
@@ -1,36 +0,0 @@
---
sidebar_position: 11
---
import Tabs from '@theme/Tabs';
import TabItem from '@theme/TabItem';
# Удалить записи
Удаляет записи из таблицы
`Функция УдалитьЗаписи(Знач Таблица, Знач Фильтры = "", Знач Соединение = "") Экспорт`
| Параметр | CLI опция | Тип | Обяз. | Назначение |
|-|-|-|-|-|
| Таблица | --table | Строка | &#x2714; | Имя таблицы |
| Фильтры | --filter | Массив Из Структура | &#x2716; | Массив фильтров. См. ПолучитьСтруктуруФильтраЗаписей |
| Соединение | --dbc | Строка, Произвольный | &#x2716; | Соединение или строка подключения |
Возвращаемое значение: Структура Из КлючИЗначение, Строка - Результат выполнения запроса
<br/>
```bsl title="Пример использования для 1С:Предприятие/OneScript"
```
docs/ru/md/PostgreSQL/Orm/Delete-records.mdx
Vendored
+68
View File
@@ -0,0 +1,68 @@
---
sidebar_position: 11
---
import Tabs from '@theme/Tabs';
import TabItem from '@theme/TabItem';
# Удалить записи
Удаляет записи из таблицы
`Функция УдалитьЗаписи(Знач Таблица, Знач Фильтры = "", Знач Соединение = "") Экспорт`
| Параметр | CLI опция | Тип | Обяз. | Назначение |
|-|-|-|-|-|
| Таблица | --table | Строка | &#x2714; | Имя таблицы |
| Фильтры | --filter | Массив Из Структура | &#x2716; | Массив фильтров. См. ПолучитьСтруктуруФильтраЗаписей |
| Соединение | --dbc | Строка, Произвольный | &#x2716; | Соединение или строка подключения |
Возвращаемое значение: Структура Из КлючИЗначение, Строка - Результат выполнения запроса
<br/>
```bsl title="Пример использования для 1С:Предприятие/OneScript"
Адрес = "93.125.42.204";
Логин = "bayselonarrend";
Пароль = "12we...";
База = "test_data";
// При использовании строки подключения инициализируется новое соединение,
// которое будет закрыто после выполнения функции.
// В случае выполнения нескольких операций желательно использовать одно соединение,
// заранее созданное функцией ОткрытьСоединение()
СтрокаПодключения = OPI_PostgreSQL.СформироватьСтрокуПодключения(Адрес, База, Логин, Пароль);
Таблица = "test_data";
Фильтры = Новый Массив;
СтруктураФильтра = Новый Структура;
СтруктураФильтра.Вставить("field", "gender");
СтруктураФильтра.Вставить("type" , "=");
СтруктураФильтра.Вставить("value", Новый Структура("VARCHAR", "Male"));
СтруктураФильтра.Вставить("raw" , Ложь);
СтруктураФильтра.Вставить("union", "AND");
Фильтры.Добавить(СтруктураФильтра);
СтруктураФильтра = Новый Структура;
СтруктураФильтра.Вставить("field", "ip_address");
СтруктураФильтра.Вставить("type" , "=");
СтруктураФильтра.Вставить("value", Новый Структура("VARCHAR", "127.0.0.1"));
СтруктураФильтра.Вставить("raw" , Ложь);
Результат = OPI_PostgreSQL.УдалитьЗаписи(Таблица, Фильтры, СтрокаПодключения);
```
docs/ru/md/PostgreSQL/Orm/Disable-all-database-connections.mdx
Vendored
+1 -1
View File
@@ -26,7 +26,7 @@ import TabItem from '@theme/TabItem';
```bsl title="Пример использования для 1С:Предприятие/OneScript"
Адрес = "93.125.42.204";
Адрес = "93.125.42.204";
Логин = "bayselonarrend";
Пароль = "12we...";
База = "testbase1";
docs/ru/md/PostgreSQL/Orm/Update-records.mdx
Vendored
+5 -8
View File
@@ -31,7 +31,7 @@ import TabItem from '@theme/TabItem';
Адрес = "93.125.42.204";
Логин = "bayselonarrend";
Пароль = "12we...";
База = "testbase1";
База = "test_data";
// При использовании строки подключения инициализируется новое соединение,
// которое будет закрыто после выполнения функции.
@@ -39,21 +39,18 @@ import TabItem from '@theme/TabItem';
// заранее созданное функцией ОткрытьСоединение()
СтрокаПодключения = OPI_PostgreSQL.СформироватьСтрокуПодключения(Адрес, База, Логин, Пароль);
Таблица = "testtable";
Таблица = "test_data";
СтруктураПолей = Новый Структура;
СтруктураПолей.Вставить("bool_field" , Новый Структура("BOOL" , Ложь));
СтруктураПолей.Вставить("oldchar_field" , Новый Структура("OLDCHAR" , 2));
СтруктураПолей.Вставить("smallint_field" , Новый Структура("SMALLINT" , 10));
СтруктураПолей.Вставить("smallserial_field", Новый Структура("SMALLSERIAL" , 10));
СтруктураПолей.Вставить("ip_address", Новый Структура("VARCHAR", "127.0.0.1"));
Фильтры = Новый Массив;
СтруктураФильтра = Новый Структура;
СтруктураФильтра.Вставить("field", "oid_field");
СтруктураФильтра.Вставить("field", "gender");
СтруктураФильтра.Вставить("type" , "=");
СтруктураФильтра.Вставить("value", Новый Структура("OID", 24576));
СтруктураФильтра.Вставить("value", Новый Структура("VARCHAR", "Male"));
СтруктураФильтра.Вставить("raw" , Ложь);
Фильтры.Добавить(СтруктураФильтра);
docs/ru/md/SQLite/Orm/Delete-posts.mdx → docs/ru/md/SQLite/Orm/Delete-records.mdx
Vendored
View File
service/dictionaries/en.json
Vendored
+6403 -6403
View File
File diff suppressed because it is too large Load Diff
src/en/OInt/core/Modules/OPI_Airtable.os
Vendored
+1 -1
View File
@@ -484,7 +484,7 @@ EndFunction
//
// Returns:
// Map Of KeyAndValue - serialized JSON response from Airtable
Function DeletePosts(Val Token, Val Base, Val Table, Val Records) Export
Function DeleteRecords(Val Token, Val Base, Val Table, Val Records) Export
OPI_TypeConversion.GetLine(Base);
OPI_TypeConversion.GetLine(Table);
src/en/OInt/core/Modules/OPI_PostgreSQL.os
Vendored
+4 -4
View File
@@ -245,7 +245,7 @@ Function DisableAllDatabaseConnections(Val Base, Val Connection = "") Export
OPI_TypeConversion.GetLine(Base);
TextSQL = "SELECT pg_terminate_backend(pid)
TextSQL = "SELECT pg_terminate_backend(pid)
|FROM pg_stat_activity
|WHERE datname = '%1' AND pid <> pg_backend_pid();";
@@ -310,7 +310,7 @@ EndFunction
// Structure Of KeyAndValue, String - Result of query execution
Function ClearTable(Val Table, Val Connection = "") Export
Result = OPI_SQLQueries.DeletePosts(OPI_PostgreSQL, Table, , Connection);
Result = OPI_SQLQueries.DeleteRecords(OPI_PostgreSQL, Table, , Connection);
Return Result;
EndFunction
@@ -408,9 +408,9 @@ EndFunction
//
// Returns:
// Structure Of KeyAndValue, String - Result of query execution
Function DeletePosts(Val Table, Val Filters = "", Val Connection = "") Export
Function DeleteRecords(Val Table, Val Filters = "", Val Connection = "") Export
Result = OPI_SQLQueries.DeletePosts(OPI_PostgreSQL, Table, Filters, Connection);
Result = OPI_SQLQueries.DeleteRecords(OPI_PostgreSQL, Table, Filters, Connection);
Return Result;
EndFunction
src/en/OInt/core/Modules/OPI_SQLite.os
Vendored
+3 -3
View File
@@ -273,9 +273,9 @@ EndFunction
//
// Returns:
// Map Of KeyAndValue - Result of query execution
Function DeletePosts(Val Table, Val Filters = "", Val Connection = "") Export
Function DeleteRecords(Val Table, Val Filters = "", Val Connection = "") Export
Result = OPI_SQLQueries.DeletePosts(OPI_SQLite, Table, Filters, Connection);
Result = OPI_SQLQueries.DeleteRecords(OPI_SQLite, Table, Filters, Connection);
Return Result;
EndFunction
@@ -307,7 +307,7 @@ EndFunction
// Map Of KeyAndValue - Result of query execution
Function ClearTable(Val Table, Val Connection = "") Export
Result = OPI_SQLQueries.DeletePosts(OPI_SQLite, Table, , Connection);
Result = OPI_SQLQueries.DeleteRecords(OPI_SQLite, Table, , Connection);
Return Result;
EndFunction
src/en/OInt/tests/Modules/internal/OPI_Tests.os
Vendored
+105 -25
View File
@@ -1243,7 +1243,7 @@ Procedure AT_CreateDeleteRecords() Export
Airtable_GetComments(TestParameters);
Airtable_DeleteComment(TestParameters);
Airtable_GetListOfRecords(TestParameters);
Airtable_DeletePosts(TestParameters);
Airtable_DeleteRecords(TestParameters);
EndProcedure
@@ -2282,7 +2282,7 @@ Procedure SQLL_ORM() Export
SQLite_AddRecords(TestParameters);
SQLite_GetRecords(TestParameters);
SQLite_UpdateRecords(TestParameters);
SQLite_DeletePosts(TestParameters);
SQLite_DeleteRecords(TestParameters);
SQLite_GetTableInformation(TestParameters);
SQLite_ClearTable(TestParameters);
SQLite_DeleteTable(TestParameters);
@@ -2295,7 +2295,7 @@ Procedure SQLL_ORM() Export
SQLite_AddRecords(TestParameters);
SQLite_GetRecords(TestParameters);
SQLite_UpdateRecords(TestParameters);
SQLite_DeletePosts(TestParameters);
SQLite_DeleteRecords(TestParameters);
SQLite_GetTableInformation(TestParameters);
SQLite_ClearTable(TestParameters);
SQLite_DeleteTable(TestParameters);
@@ -2319,6 +2319,7 @@ Procedure Postgres_CommonMethods() Export
OPI_TestDataRetrieval.ParameterToCollection("PG_IP" , TestParameters);
OPI_TestDataRetrieval.ParameterToCollection("PG_Password", TestParameters);
OPI_TestDataRetrieval.ParameterToCollection("Picture" , TestParameters);
OPI_TestDataRetrieval.ParameterToCollection("SQL" , TestParameters);
PostgreSQL_GenerateConnectionString(TestParameters);
PostgreSQL_CreateConnection(TestParameters);
@@ -2341,6 +2342,7 @@ Procedure Postgres_ORM() Export
PostgreSQL_AddRecords(TestParameters);
PostgreSQL_GetRecords(TestParameters);
PostgreSQL_UpdateRecords(TestParameters);
PostgreSQL_DeleteRecords(TestParameters);
PostgreSQL_ClearTable(TestParameters);
PostgreSQL_DeleteTable(TestParameters);
PostgreSQL_DisableAllDatabaseConnections(TestParameters);
@@ -6780,7 +6782,7 @@ Procedure Airtable_CreatePosts(FunctionParameters)
EndDo;
OPI_Airtable.DeletePosts(Token, Base, Table, ArrayOfDeletions);
OPI_Airtable.DeleteRecords(Token, Base, Table, ArrayOfDeletions);
// Single
@@ -6896,18 +6898,18 @@ Procedure Airtable_GetListOfRecords(FunctionParameters)
EndProcedure
Procedure Airtable_DeletePosts(FunctionParameters)
Procedure Airtable_DeleteRecords(FunctionParameters)
Token = FunctionParameters["Airtable_Token"];
Base = FunctionParameters["Airtable_Base"];
Table = FunctionParameters["Airtable_Table"];
Record = FunctionParameters["Airtable_Record"];
Result = OPI_Airtable.DeletePosts(Token, Base, Table, Record);
Result = OPI_Airtable.DeleteRecords(Token, Base, Table, Record);
// END
OPI_TestDataRetrieval.WriteLog(Result, "DeletePosts", "Airtable");
OPI_TestDataRetrieval.WriteLog(Result, "DeleteRecords", "Airtable");
OPI_TestDataRetrieval.Check_ATRecords(Result);
EndProcedure
@@ -17203,7 +17205,7 @@ Procedure SQLite_UpdateRecords(FunctionParameters)
EndProcedure
Procedure SQLite_DeletePosts(FunctionParameters)
Procedure SQLite_DeleteRecords(FunctionParameters)
Base = FunctionParameters["SQLite_DB"];
Table = "test";
@@ -17220,11 +17222,11 @@ Procedure SQLite_DeletePosts(FunctionParameters)
Filters.Add(FilterStructure);
Result = OPI_SQLite.DeletePosts(Table, FilterStructure, Base);
Result = OPI_SQLite.DeleteRecords(Table, FilterStructure, Base);
// END
OPI_TestDataRetrieval.WriteLog(Result, "DeletePosts", "SQLite");
OPI_TestDataRetrieval.WriteLog(Result, "DeleteRecords", "SQLite");
OPI_TestDataRetrieval.Check_SQLiteSuccess(Result);
Check = OPI_SQLite.GetRecords(Table, "['name','salary']", Filters, , , Base);
@@ -17407,9 +17409,10 @@ Procedure PostgreSQL_ExecuteSQLQuery(FunctionParameters)
ConnectionString = OPI_PostgreSQL.GenerateConnectionString(Address, Base, Login, Password);
Connection = OPI_PostgreSQL.CreateConnection(ConnectionString);
OPI_PostgreSQL.DeleteTable("users", Connection); // SKIP
OPI_PostgreSQL.DeleteTable("users" , Connection); // SKIP
OPI_PostgreSQL.DeleteTable("test_data", Connection); // SKIP
Deletion = OPI_PostgreSQL.DeleteTable("test_table", Connection); // SKIP
OPI_TestDataRetrieval.WriteLog(Connection, "ExecuteSQLQuery (deleting)", "PostgreSQL"); // SKIP
OPI_TestDataRetrieval.WriteLog(Connection, "ExecuteSQLQuery (deleting 1)", "PostgreSQL"); // SKIP
OPI_TestDataRetrieval.WriteLog(Connection, "ExecuteSQLQuery (connect)", "PostgreSQL"); // SKIP
OPI_TestDataRetrieval.Check_AddIn(Connection, "AddIn.OPI_PostgreSQL.Main"); // SKIP
@@ -17484,6 +17487,15 @@ Procedure PostgreSQL_ExecuteSQLQuery(FunctionParameters)
OPI_TestDataRetrieval.WriteLog(Result, "ExecuteSQLQuery (Transaction)", "PostgreSQL"); // SKIP
OPI_TestDataRetrieval.Check_ResultTrue(Result); // SKIP
// SQL query from file
SQLFile = FunctionParameters["SQL"]; // Binary Data, URL or path to file
Result = OPI_PostgreSQL.ExecuteSQLQuery(SQLFile, , , Connection);
OPI_TestDataRetrieval.WriteLog(Result, "ExecuteSQLQuery (file)", "PostgreSQL"); // SKIP
OPI_TestDataRetrieval.Check_ResultTrue(Result); // SKIP
Closing = OPI_PostgreSQL.CloseConnection(Connection);
// END
@@ -17772,7 +17784,7 @@ Procedure PostgreSQL_UpdateRecords(FunctionParameters)
Address = FunctionParameters["PG_IP"];
Login = "bayselonarrend";
Password = FunctionParameters["PG_Password"];
Base = "testbase1";
Base = "test_data";
// When using the connection string, a new connection is initialised,
// which will be closed after the function is executed.
@@ -17780,25 +17792,26 @@ Procedure PostgreSQL_UpdateRecords(FunctionParameters)
// previously created by the CreateConnection function()
ConnectionString = OPI_PostgreSQL.GenerateConnectionString(Address, Base, Login, Password);
Table = "testtable";
Table = "test_data";
FieldsStructure = New Structure;
FieldsStructure.Insert("bool_field" , New Structure("BOOL" , False));
FieldsStructure.Insert("oldchar_field" , New Structure("OLDCHAR" , 2));
FieldsStructure.Insert("smallint_field" , New Structure("SMALLINT" , 10));
FieldsStructure.Insert("smallserial_field", New Structure("SMALLSERIAL" , 10));
FieldsStructure.Insert("ip_address", New Structure("VARCHAR", "127.0.0.1"));
Filters = New Array;
FilterStructure = New Structure;
FilterStructure.Insert("field", "oid_field");
FilterStructure.Insert("field", "gender");
FilterStructure.Insert("type" , "=");
FilterStructure.Insert("value", New Structure("OID", 24576));
FilterStructure.Insert("value", New Structure("VARCHAR", "Male"));
FilterStructure.Insert("raw" , False);
Filters.Add(FilterStructure);
Count = OPI_PostgreSQl.GetRecords(Table, , Filters, , , ConnectionString); // SKIP
OPI_TestDataRetrieval.WriteLog(Count, "UpdateRecords (amount)", "PostgreSQL"); // SKIP
Count = Count["data"].Count(); // SKIP
Result = OPI_PostgreSQl.UpdateRecords(Table, FieldsStructure, FilterStructure, ConnectionString);
// END
@@ -17807,14 +17820,72 @@ Procedure PostgreSQL_UpdateRecords(FunctionParameters)
OPI_TestDataRetrieval.Check_ResultTrue(Result);
Check = OPI_PostgreSQl.GetRecords(Table
, "['bool_field'
|,'smallserial_field'
|, 'smallint_field']"
, "['ip_address']"
, Filters, , , ConnectionString);
OPI_TestDataRetrieval.WriteLog(Check, "UpdateRecords (check)", "PostgreSQL");
OPI_TestDataRetrieval.Check_ResultTrue(Check);
OPI_TestDataRetrieval.Check_SQLiteFieldsValues(Check["data"][0], FieldsStructure);
OPI_TestDataRetrieval.Check_Array(Check["data"], Count);
For N = 0 To Check["data"].UBound() Do
OPI_TestDataRetrieval.Check_SQLiteFieldsValues(Check["data"][N], FieldsStructure);
EndDo;
EndProcedure
Procedure PostgreSQL_DeleteRecords(FunctionParameters)
Address = FunctionParameters["PG_IP"];
Login = "bayselonarrend";
Password = FunctionParameters["PG_Password"];
Base = "test_data";
// When using the connection string, a new connection is initialised,
// which will be closed after the function is executed.
// If several operations are performed, it is desirable to use one connection,
// previously created by the CreateConnection function()
ConnectionString = OPI_PostgreSQL.GenerateConnectionString(Address, Base, Login, Password);
Table = "test_data";
Filters = New Array;
FilterStructure = New Structure;
FilterStructure.Insert("field", "gender");
FilterStructure.Insert("type" , "=");
FilterStructure.Insert("value", New Structure("VARCHAR", "Male"));
FilterStructure.Insert("raw" , False);
FilterStructure.Insert("union", "AND");
Filters.Add(FilterStructure);
FilterStructure = New Structure;
FilterStructure.Insert("field", "ip_address");
FilterStructure.Insert("type" , "=");
FilterStructure.Insert("value", New Structure("VARCHAR", "127.0.0.1"));
FilterStructure.Insert("raw" , False);
Obtaining = OPI_PostgreSQL.GetRecords(Table, , Filters, , , ConnectionString); // SKIP
Result = OPI_PostgreSQL.DeleteRecords(Table, Filters, ConnectionString);
// END
OPI_TestDataRetrieval.WriteLog(Obtaining, "DeleteRecords (get)", "PostgreSQL");
OPI_TestDataRetrieval.Check_ResultTrue(Result);
Count = Obtaining["data"].Count();
Residue = 100 - Count;
OPI_TestDataRetrieval.WriteLog(Result, "DeleteRecords", "PostgreSQL");
OPI_TestDataRetrieval.Check_ResultTrue(Result);
Result = OPI_PostgreSQL.GetRecords(Table, , , , , ConnectionString);
OPI_TestDataRetrieval.WriteLog(Result, "DeleteRecords (check)", "PostgreSQL");
OPI_TestDataRetrieval.Check_ResultTrue(Result);
OPI_TestDataRetrieval.Check_Array(Result["data"], Residue);
EndProcedure
@@ -17840,6 +17911,15 @@ Procedure PostgreSQL_DeleteTable(FunctionParameters)
OPI_TestDataRetrieval.WriteLog(Result, "DeleteTable", "PostgreSQL");
OPI_TestDataRetrieval.Check_ResultTrue(Result);
Base = "test_data";
Table = "test_data";
ConnectionString = OPI_PostgreSQL.GenerateConnectionString(Address, Base, Login, Password);
Result = OPI_PostgreSQL.DeleteTable(Table, ConnectionString);
OPI_TestDataRetrieval.WriteLog(Result, "DeleteTable (test)", "PostgreSQL");
OPI_TestDataRetrieval.Check_ResultTrue(Result);
EndProcedure
Procedure PostgreSQL_DeleteDatabase(FunctionParameters)
@@ -17930,7 +18010,7 @@ EndProcedure
Procedure PostgreSQL_DisableAllDatabaseConnections(FunctionParameters)
Address = FunctionParameters["PG_IP"];
Address = FunctionParameters["PG_IP"];
Login = "bayselonarrend";
Password = FunctionParameters["PG_Password"];
Base = "testbase1";
src/en/OInt/tests/Modules/internal/OPI_TestsCLI.os
Vendored
+9 -9
View File
@@ -1241,7 +1241,7 @@ Procedure CLI_AT_CreateDeleteRecords() Export
CLI_Airtable_GetComments(TestParameters);
CLI_Airtable_DeleteComment(TestParameters);
CLI_Airtable_GetListOfRecords(TestParameters);
CLI_Airtable_DeletePosts(TestParameters);
CLI_Airtable_DeleteRecords(TestParameters);
EndProcedure
@@ -2273,7 +2273,7 @@ Procedure CLI_SQLL_ORM() Export
CLI_SQLite_AddRecords(TestParameters);
CLI_SQLite_GetRecords(TestParameters);
CLI_SQLite_UpdateRecords(TestParameters);
CLI_SQLite_DeletePosts(TestParameters);
CLI_SQLite_DeleteRecords(TestParameters);
CLI_SQLite_GetTableInformation(TestParameters);
CLI_SQLite_ClearTable(TestParameters);
CLI_SQLite_DeleteTable(TestParameters);
@@ -7817,7 +7817,7 @@ Procedure CLI_Airtable_CreatePosts(FunctionParameters)
EndDo;
OPI_Airtable.DeletePosts(Token, Base, Table, ArrayOfDeletions);
OPI_Airtable.DeleteRecords(Token, Base, Table, ArrayOfDeletions);
// Single
@@ -7969,7 +7969,7 @@ Procedure CLI_Airtable_GetListOfRecords(FunctionParameters)
EndProcedure
Procedure CLI_Airtable_DeletePosts(FunctionParameters)
Procedure CLI_Airtable_DeleteRecords(FunctionParameters)
Token = FunctionParameters["Airtable_Token"];
Base = FunctionParameters["Airtable_Base"];
@@ -7982,9 +7982,9 @@ Procedure CLI_Airtable_DeletePosts(FunctionParameters)
Options.Insert("table" , Table);
Options.Insert("records", Record);
Result = OPI_TestDataRetrieval.ExecuteTestCLI("airtable", "DeletePosts", Options);
Result = OPI_TestDataRetrieval.ExecuteTestCLI("airtable", "DeleteRecords", Options);
OPI_TestDataRetrieval.WriteLogCLI(Result, "DeletePosts", "Airtable");
OPI_TestDataRetrieval.WriteLogCLI(Result, "DeleteRecords", "Airtable");
OPI_TestDataRetrieval.Check_ATRecords(Result);
EndProcedure
@@ -19291,7 +19291,7 @@ Procedure CLI_SQLite_UpdateRecords(FunctionParameters)
EndProcedure
Procedure CLI_SQLite_DeletePosts(FunctionParameters)
Procedure CLI_SQLite_DeleteRecords(FunctionParameters)
Base = FunctionParameters["SQLite_DB"];
Table = "test";
@@ -19313,9 +19313,9 @@ Procedure CLI_SQLite_DeletePosts(FunctionParameters)
Options.Insert("filter", FilterStructure);
Options.Insert("db" , Base);
Result = OPI_TestDataRetrieval.ExecuteTestCLI("sqlite", "DeletePosts", Options);
Result = OPI_TestDataRetrieval.ExecuteTestCLI("sqlite", "DeleteRecords", Options);
OPI_TestDataRetrieval.WriteLogCLI(Result, "DeletePosts", "SQLite");
OPI_TestDataRetrieval.WriteLogCLI(Result, "DeleteRecords", "SQLite");
OPI_TestDataRetrieval.Check_SQLiteSuccess(Result);
Options = New Structure;
src/en/OInt/tools/Modules/OPI_SQLQueries.os
Vendored
+1 -1
View File
@@ -167,7 +167,7 @@ Function UpdateRecords(Val Module
EndFunction
Function DeletePosts(Val Module, Val Table, Val Filters = "", Val Connection = "") Export
Function DeleteRecords(Val Module, Val Table, Val Filters = "", Val Connection = "") Export
Scheme = NewSQLScheme("DELETE", Module);
src/en/OPI/src/CommonModules/OPI_Airtable/Module.bsl
Vendored
+1 -1
View File
@@ -484,7 +484,7 @@ EndFunction
//
// Returns:
// Map Of KeyAndValue - serialized JSON response from Airtable
Function DeletePosts(Val Token, Val Base, Val Table, Val Records) Export
Function DeleteRecords(Val Token, Val Base, Val Table, Val Records) Export
OPI_TypeConversion.GetLine(Base);
OPI_TypeConversion.GetLine(Table);
src/en/OPI/src/CommonModules/OPI_PostgreSQL/Module.bsl
Vendored
+4 -4
View File
@@ -245,7 +245,7 @@ Function DisableAllDatabaseConnections(Val Base, Val Connection = "") Export
OPI_TypeConversion.GetLine(Base);
TextSQL = "SELECT pg_terminate_backend(pid)
TextSQL = "SELECT pg_terminate_backend(pid)
|FROM pg_stat_activity
|WHERE datname = '%1' AND pid <> pg_backend_pid();";
@@ -310,7 +310,7 @@ EndFunction
// Structure Of KeyAndValue, String - Result of query execution
Function ClearTable(Val Table, Val Connection = "") Export
Result = OPI_SQLQueries.DeletePosts(OPI_PostgreSQL, Table, , Connection);
Result = OPI_SQLQueries.DeleteRecords(OPI_PostgreSQL, Table, , Connection);
Return Result;
EndFunction
@@ -408,9 +408,9 @@ EndFunction
//
// Returns:
// Structure Of KeyAndValue, String - Result of query execution
Function DeletePosts(Val Table, Val Filters = "", Val Connection = "") Export
Function DeleteRecords(Val Table, Val Filters = "", Val Connection = "") Export
Result = OPI_SQLQueries.DeletePosts(OPI_PostgreSQL, Table, Filters, Connection);
Result = OPI_SQLQueries.DeleteRecords(OPI_PostgreSQL, Table, Filters, Connection);
Return Result;
EndFunction
src/en/OPI/src/CommonModules/OPI_SQLQueries/Module.bsl
Vendored
+1 -1
View File
@@ -167,7 +167,7 @@ Function UpdateRecords(Val Module
EndFunction
Function DeletePosts(Val Module, Val Table, Val Filters = "", Val Connection = "") Export
Function DeleteRecords(Val Module, Val Table, Val Filters = "", Val Connection = "") Export
Scheme = NewSQLScheme("DELETE", Module);
src/en/OPI/src/CommonModules/OPI_SQLite/Module.bsl
Vendored
+3 -3
View File
@@ -273,9 +273,9 @@ EndFunction
//
// Returns:
// Map Of KeyAndValue - Result of query execution
Function DeletePosts(Val Table, Val Filters = "", Val Connection = "") Export
Function DeleteRecords(Val Table, Val Filters = "", Val Connection = "") Export
Result = OPI_SQLQueries.DeletePosts(OPI_SQLite, Table, Filters, Connection);
Result = OPI_SQLQueries.DeleteRecords(OPI_SQLite, Table, Filters, Connection);
Return Result;
EndFunction
@@ -307,7 +307,7 @@ EndFunction
// Map Of KeyAndValue - Result of query execution
Function ClearTable(Val Table, Val Connection = "") Export
Result = OPI_SQLQueries.DeletePosts(OPI_SQLite, Table, , Connection);
Result = OPI_SQLQueries.DeleteRecords(OPI_SQLite, Table, , Connection);
Return Result;
EndFunction
src/en/OPI/src/CommonModules/OPI_Tests/Module.bsl
Vendored
+105 -25
View File
@@ -1243,7 +1243,7 @@ Procedure AT_CreateDeleteRecords() Export
Airtable_GetComments(TestParameters);
Airtable_DeleteComment(TestParameters);
Airtable_GetListOfRecords(TestParameters);
Airtable_DeletePosts(TestParameters);
Airtable_DeleteRecords(TestParameters);
EndProcedure
@@ -2282,7 +2282,7 @@ Procedure SQLL_ORM() Export
SQLite_AddRecords(TestParameters);
SQLite_GetRecords(TestParameters);
SQLite_UpdateRecords(TestParameters);
SQLite_DeletePosts(TestParameters);
SQLite_DeleteRecords(TestParameters);
SQLite_GetTableInformation(TestParameters);
SQLite_ClearTable(TestParameters);
SQLite_DeleteTable(TestParameters);
@@ -2295,7 +2295,7 @@ Procedure SQLL_ORM() Export
SQLite_AddRecords(TestParameters);
SQLite_GetRecords(TestParameters);
SQLite_UpdateRecords(TestParameters);
SQLite_DeletePosts(TestParameters);
SQLite_DeleteRecords(TestParameters);
SQLite_GetTableInformation(TestParameters);
SQLite_ClearTable(TestParameters);
SQLite_DeleteTable(TestParameters);
@@ -2319,6 +2319,7 @@ Procedure Postgres_CommonMethods() Export
OPI_TestDataRetrieval.ParameterToCollection("PG_IP" , TestParameters);
OPI_TestDataRetrieval.ParameterToCollection("PG_Password", TestParameters);
OPI_TestDataRetrieval.ParameterToCollection("Picture" , TestParameters);
OPI_TestDataRetrieval.ParameterToCollection("SQL" , TestParameters);
PostgreSQL_GenerateConnectionString(TestParameters);
PostgreSQL_CreateConnection(TestParameters);
@@ -2341,6 +2342,7 @@ Procedure Postgres_ORM() Export
PostgreSQL_AddRecords(TestParameters);
PostgreSQL_GetRecords(TestParameters);
PostgreSQL_UpdateRecords(TestParameters);
PostgreSQL_DeleteRecords(TestParameters);
PostgreSQL_ClearTable(TestParameters);
PostgreSQL_DeleteTable(TestParameters);
PostgreSQL_DisableAllDatabaseConnections(TestParameters);
@@ -6780,7 +6782,7 @@ Procedure Airtable_CreatePosts(FunctionParameters)
EndDo;
OPI_Airtable.DeletePosts(Token, Base, Table, ArrayOfDeletions);
OPI_Airtable.DeleteRecords(Token, Base, Table, ArrayOfDeletions);
// Single
@@ -6896,18 +6898,18 @@ Procedure Airtable_GetListOfRecords(FunctionParameters)
EndProcedure
Procedure Airtable_DeletePosts(FunctionParameters)
Procedure Airtable_DeleteRecords(FunctionParameters)
Token = FunctionParameters["Airtable_Token"];
Base = FunctionParameters["Airtable_Base"];
Table = FunctionParameters["Airtable_Table"];
Record = FunctionParameters["Airtable_Record"];
Result = OPI_Airtable.DeletePosts(Token, Base, Table, Record);
Result = OPI_Airtable.DeleteRecords(Token, Base, Table, Record);
// END
OPI_TestDataRetrieval.WriteLog(Result, "DeletePosts", "Airtable");
OPI_TestDataRetrieval.WriteLog(Result, "DeleteRecords", "Airtable");
OPI_TestDataRetrieval.Check_ATRecords(Result);
EndProcedure
@@ -17203,7 +17205,7 @@ Procedure SQLite_UpdateRecords(FunctionParameters)
EndProcedure
Procedure SQLite_DeletePosts(FunctionParameters)
Procedure SQLite_DeleteRecords(FunctionParameters)
Base = FunctionParameters["SQLite_DB"];
Table = "test";
@@ -17220,11 +17222,11 @@ Procedure SQLite_DeletePosts(FunctionParameters)
Filters.Add(FilterStructure);
Result = OPI_SQLite.DeletePosts(Table, FilterStructure, Base);
Result = OPI_SQLite.DeleteRecords(Table, FilterStructure, Base);
// END
OPI_TestDataRetrieval.WriteLog(Result, "DeletePosts", "SQLite");
OPI_TestDataRetrieval.WriteLog(Result, "DeleteRecords", "SQLite");
OPI_TestDataRetrieval.Check_SQLiteSuccess(Result);
Check = OPI_SQLite.GetRecords(Table, "['name','salary']", Filters, , , Base);
@@ -17407,9 +17409,10 @@ Procedure PostgreSQL_ExecuteSQLQuery(FunctionParameters)
ConnectionString = OPI_PostgreSQL.GenerateConnectionString(Address, Base, Login, Password);
Connection = OPI_PostgreSQL.CreateConnection(ConnectionString);
OPI_PostgreSQL.DeleteTable("users", Connection); // SKIP
OPI_PostgreSQL.DeleteTable("users" , Connection); // SKIP
OPI_PostgreSQL.DeleteTable("test_data", Connection); // SKIP
Deletion = OPI_PostgreSQL.DeleteTable("test_table", Connection); // SKIP
OPI_TestDataRetrieval.WriteLog(Connection, "ExecuteSQLQuery (deleting)", "PostgreSQL"); // SKIP
OPI_TestDataRetrieval.WriteLog(Connection, "ExecuteSQLQuery (deleting 1)", "PostgreSQL"); // SKIP
OPI_TestDataRetrieval.WriteLog(Connection, "ExecuteSQLQuery (connect)", "PostgreSQL"); // SKIP
OPI_TestDataRetrieval.Check_AddIn(Connection, "AddIn.OPI_PostgreSQL.Main"); // SKIP
@@ -17484,6 +17487,15 @@ Procedure PostgreSQL_ExecuteSQLQuery(FunctionParameters)
OPI_TestDataRetrieval.WriteLog(Result, "ExecuteSQLQuery (Transaction)", "PostgreSQL"); // SKIP
OPI_TestDataRetrieval.Check_ResultTrue(Result); // SKIP
// SQL query from file
SQLFile = FunctionParameters["SQL"]; // Binary Data, URL or path to file
Result = OPI_PostgreSQL.ExecuteSQLQuery(SQLFile, , , Connection);
OPI_TestDataRetrieval.WriteLog(Result, "ExecuteSQLQuery (file)", "PostgreSQL"); // SKIP
OPI_TestDataRetrieval.Check_ResultTrue(Result); // SKIP
Closing = OPI_PostgreSQL.CloseConnection(Connection);
// END
@@ -17772,7 +17784,7 @@ Procedure PostgreSQL_UpdateRecords(FunctionParameters)
Address = FunctionParameters["PG_IP"];
Login = "bayselonarrend";
Password = FunctionParameters["PG_Password"];
Base = "testbase1";
Base = "test_data";
// When using the connection string, a new connection is initialised,
// which will be closed after the function is executed.
@@ -17780,25 +17792,26 @@ Procedure PostgreSQL_UpdateRecords(FunctionParameters)
// previously created by the CreateConnection function()
ConnectionString = OPI_PostgreSQL.GenerateConnectionString(Address, Base, Login, Password);
Table = "testtable";
Table = "test_data";
FieldsStructure = New Structure;
FieldsStructure.Insert("bool_field" , New Structure("BOOL" , False));
FieldsStructure.Insert("oldchar_field" , New Structure("OLDCHAR" , 2));
FieldsStructure.Insert("smallint_field" , New Structure("SMALLINT" , 10));
FieldsStructure.Insert("smallserial_field", New Structure("SMALLSERIAL" , 10));
FieldsStructure.Insert("ip_address", New Structure("VARCHAR", "127.0.0.1"));
Filters = New Array;
FilterStructure = New Structure;
FilterStructure.Insert("field", "oid_field");
FilterStructure.Insert("field", "gender");
FilterStructure.Insert("type" , "=");
FilterStructure.Insert("value", New Structure("OID", 24576));
FilterStructure.Insert("value", New Structure("VARCHAR", "Male"));
FilterStructure.Insert("raw" , False);
Filters.Add(FilterStructure);
Count = OPI_PostgreSQl.GetRecords(Table, , Filters, , , ConnectionString); // SKIP
OPI_TestDataRetrieval.WriteLog(Count, "UpdateRecords (amount)", "PostgreSQL"); // SKIP
Count = Count["data"].Count(); // SKIP
Result = OPI_PostgreSQl.UpdateRecords(Table, FieldsStructure, FilterStructure, ConnectionString);
// END
@@ -17807,14 +17820,72 @@ Procedure PostgreSQL_UpdateRecords(FunctionParameters)
OPI_TestDataRetrieval.Check_ResultTrue(Result);
Check = OPI_PostgreSQl.GetRecords(Table
, "['bool_field'
|,'smallserial_field'
|, 'smallint_field']"
, "['ip_address']"
, Filters, , , ConnectionString);
OPI_TestDataRetrieval.WriteLog(Check, "UpdateRecords (check)", "PostgreSQL");
OPI_TestDataRetrieval.Check_ResultTrue(Check);
OPI_TestDataRetrieval.Check_SQLiteFieldsValues(Check["data"][0], FieldsStructure);
OPI_TestDataRetrieval.Check_Array(Check["data"], Count);
For N = 0 To Check["data"].UBound() Do
OPI_TestDataRetrieval.Check_SQLiteFieldsValues(Check["data"][N], FieldsStructure);
EndDo;
EndProcedure
Procedure PostgreSQL_DeleteRecords(FunctionParameters)
Address = FunctionParameters["PG_IP"];
Login = "bayselonarrend";
Password = FunctionParameters["PG_Password"];
Base = "test_data";
// When using the connection string, a new connection is initialised,
// which will be closed after the function is executed.
// If several operations are performed, it is desirable to use one connection,
// previously created by the CreateConnection function()
ConnectionString = OPI_PostgreSQL.GenerateConnectionString(Address, Base, Login, Password);
Table = "test_data";
Filters = New Array;
FilterStructure = New Structure;
FilterStructure.Insert("field", "gender");
FilterStructure.Insert("type" , "=");
FilterStructure.Insert("value", New Structure("VARCHAR", "Male"));
FilterStructure.Insert("raw" , False);
FilterStructure.Insert("union", "AND");
Filters.Add(FilterStructure);
FilterStructure = New Structure;
FilterStructure.Insert("field", "ip_address");
FilterStructure.Insert("type" , "=");
FilterStructure.Insert("value", New Structure("VARCHAR", "127.0.0.1"));
FilterStructure.Insert("raw" , False);
Obtaining = OPI_PostgreSQL.GetRecords(Table, , Filters, , , ConnectionString); // SKIP
Result = OPI_PostgreSQL.DeleteRecords(Table, Filters, ConnectionString);
// END
OPI_TestDataRetrieval.WriteLog(Obtaining, "DeleteRecords (get)", "PostgreSQL");
OPI_TestDataRetrieval.Check_ResultTrue(Result);
Count = Obtaining["data"].Count();
Residue = 100 - Count;
OPI_TestDataRetrieval.WriteLog(Result, "DeleteRecords", "PostgreSQL");
OPI_TestDataRetrieval.Check_ResultTrue(Result);
Result = OPI_PostgreSQL.GetRecords(Table, , , , , ConnectionString);
OPI_TestDataRetrieval.WriteLog(Result, "DeleteRecords (check)", "PostgreSQL");
OPI_TestDataRetrieval.Check_ResultTrue(Result);
OPI_TestDataRetrieval.Check_Array(Result["data"], Residue);
EndProcedure
@@ -17840,6 +17911,15 @@ Procedure PostgreSQL_DeleteTable(FunctionParameters)
OPI_TestDataRetrieval.WriteLog(Result, "DeleteTable", "PostgreSQL");
OPI_TestDataRetrieval.Check_ResultTrue(Result);
Base = "test_data";
Table = "test_data";
ConnectionString = OPI_PostgreSQL.GenerateConnectionString(Address, Base, Login, Password);
Result = OPI_PostgreSQL.DeleteTable(Table, ConnectionString);
OPI_TestDataRetrieval.WriteLog(Result, "DeleteTable (test)", "PostgreSQL");
OPI_TestDataRetrieval.Check_ResultTrue(Result);
EndProcedure
Procedure PostgreSQL_DeleteDatabase(FunctionParameters)
@@ -17930,7 +18010,7 @@ EndProcedure
Procedure PostgreSQL_DisableAllDatabaseConnections(FunctionParameters)
Address = FunctionParameters["PG_IP"];
Address = FunctionParameters["PG_IP"];
Login = "bayselonarrend";
Password = FunctionParameters["PG_Password"];
Base = "testbase1";
src/en/OPI/src/CommonModules/OPI_TestsCLI/Module.bsl
Vendored
+9 -9
View File
@@ -1241,7 +1241,7 @@ Procedure CLI_AT_CreateDeleteRecords() Export
CLI_Airtable_GetComments(TestParameters);
CLI_Airtable_DeleteComment(TestParameters);
CLI_Airtable_GetListOfRecords(TestParameters);
CLI_Airtable_DeletePosts(TestParameters);
CLI_Airtable_DeleteRecords(TestParameters);
EndProcedure
@@ -2273,7 +2273,7 @@ Procedure CLI_SQLL_ORM() Export
CLI_SQLite_AddRecords(TestParameters);
CLI_SQLite_GetRecords(TestParameters);
CLI_SQLite_UpdateRecords(TestParameters);
CLI_SQLite_DeletePosts(TestParameters);
CLI_SQLite_DeleteRecords(TestParameters);
CLI_SQLite_GetTableInformation(TestParameters);
CLI_SQLite_ClearTable(TestParameters);
CLI_SQLite_DeleteTable(TestParameters);
@@ -7817,7 +7817,7 @@ Procedure CLI_Airtable_CreatePosts(FunctionParameters)
EndDo;
OPI_Airtable.DeletePosts(Token, Base, Table, ArrayOfDeletions);
OPI_Airtable.DeleteRecords(Token, Base, Table, ArrayOfDeletions);
// Single
@@ -7969,7 +7969,7 @@ Procedure CLI_Airtable_GetListOfRecords(FunctionParameters)
EndProcedure
Procedure CLI_Airtable_DeletePosts(FunctionParameters)
Procedure CLI_Airtable_DeleteRecords(FunctionParameters)
Token = FunctionParameters["Airtable_Token"];
Base = FunctionParameters["Airtable_Base"];
@@ -7982,9 +7982,9 @@ Procedure CLI_Airtable_DeletePosts(FunctionParameters)
Options.Insert("table" , Table);
Options.Insert("records", Record);
Result = OPI_TestDataRetrieval.ExecuteTestCLI("airtable", "DeletePosts", Options);
Result = OPI_TestDataRetrieval.ExecuteTestCLI("airtable", "DeleteRecords", Options);
OPI_TestDataRetrieval.WriteLogCLI(Result, "DeletePosts", "Airtable");
OPI_TestDataRetrieval.WriteLogCLI(Result, "DeleteRecords", "Airtable");
OPI_TestDataRetrieval.Check_ATRecords(Result);
EndProcedure
@@ -19291,7 +19291,7 @@ Procedure CLI_SQLite_UpdateRecords(FunctionParameters)
EndProcedure
Procedure CLI_SQLite_DeletePosts(FunctionParameters)
Procedure CLI_SQLite_DeleteRecords(FunctionParameters)
Base = FunctionParameters["SQLite_DB"];
Table = "test";
@@ -19313,9 +19313,9 @@ Procedure CLI_SQLite_DeletePosts(FunctionParameters)
Options.Insert("filter", FilterStructure);
Options.Insert("db" , Base);
Result = OPI_TestDataRetrieval.ExecuteTestCLI("sqlite", "DeletePosts", Options);
Result = OPI_TestDataRetrieval.ExecuteTestCLI("sqlite", "DeleteRecords", Options);
OPI_TestDataRetrieval.WriteLogCLI(Result, "DeletePosts", "SQLite");
OPI_TestDataRetrieval.WriteLogCLI(Result, "DeleteRecords", "SQLite");
OPI_TestDataRetrieval.Check_SQLiteSuccess(Result);
Options = New Structure;
src/en/cli/data/Classes/internal/Classes/airtable.os
Vendored
+8 -8
View File
@@ -550,8 +550,8 @@
NewLine = CompositionTable.Add();
NewLine.Библиотека = "airtable";
NewLine.Модуль = "OPI_Airtable";
NewLine.Метод = "DeletePosts";
NewLine.МетодПоиска = "DELETEPOSTS";
NewLine.Метод = "DeleteRecords";
NewLine.МетодПоиска = "DELETERECORDS";
NewLine.Параметр = "--token";
NewLine.Описание = "Token";
NewLine.Область = "Record management";
@@ -561,8 +561,8 @@
NewLine = CompositionTable.Add();
NewLine.Библиотека = "airtable";
NewLine.Модуль = "OPI_Airtable";
NewLine.Метод = "DeletePosts";
NewLine.МетодПоиска = "DELETEPOSTS";
NewLine.Метод = "DeleteRecords";
NewLine.МетодПоиска = "DELETERECORDS";
NewLine.Параметр = "--base";
NewLine.Описание = "Database identifier";
NewLine.Область = "Record management";
@@ -571,8 +571,8 @@
NewLine = CompositionTable.Add();
NewLine.Библиотека = "airtable";
NewLine.Модуль = "OPI_Airtable";
NewLine.Метод = "DeletePosts";
NewLine.МетодПоиска = "DELETEPOSTS";
NewLine.Метод = "DeleteRecords";
NewLine.МетодПоиска = "DELETERECORDS";
NewLine.Параметр = "--table";
NewLine.Описание = "Table identifier";
NewLine.Область = "Record management";
@@ -581,8 +581,8 @@
NewLine = CompositionTable.Add();
NewLine.Библиотека = "airtable";
NewLine.Модуль = "OPI_Airtable";
NewLine.Метод = "DeletePosts";
NewLine.МетодПоиска = "DELETEPOSTS";
NewLine.Метод = "DeleteRecords";
NewLine.МетодПоиска = "DELETERECORDS";
NewLine.Параметр = "--records";
NewLine.Описание = "Identifier or array of record identifiers";
NewLine.Область = "Record management";
src/en/cli/data/Classes/internal/Classes/postgres.os
Vendored
+8 -8
View File
@@ -127,7 +127,7 @@
NewLine.Библиотека = "postgres";
NewLine.Модуль = "OPI_PostgreSQL";
NewLine.Метод = "DeleteDatabase";
NewLine.МетодПоиска = "DeleteDatabase";
NewLine.МетодПоиска = "DELETEDATABASE";
NewLine.Параметр = "--base";
NewLine.Описание = "Database name";
NewLine.Область = "Orm";
@@ -138,7 +138,7 @@
NewLine.Библиотека = "postgres";
NewLine.Модуль = "OPI_PostgreSQL";
NewLine.Метод = "DeleteDatabase";
NewLine.МетодПоиска = "DeleteDatabase";
NewLine.МетодПоиска = "DELETEDATABASE";
NewLine.Параметр = "--dbc";
NewLine.Описание = "Connection or connection string (optional, def. val. - Empty value)";
NewLine.Область = "Orm";
@@ -405,8 +405,8 @@
NewLine = CompositionTable.Add();
NewLine.Библиотека = "postgres";
NewLine.Модуль = "OPI_PostgreSQL";
NewLine.Метод = "DeletePosts";
NewLine.МетодПоиска = "DELETEPOSTS";
NewLine.Метод = "DeleteRecords";
NewLine.МетодПоиска = "DELETERECORDS";
NewLine.Параметр = "--table";
NewLine.Описание = "Table name";
NewLine.Область = "Orm";
@@ -416,8 +416,8 @@
NewLine = CompositionTable.Add();
NewLine.Библиотека = "postgres";
NewLine.Модуль = "OPI_PostgreSQL";
NewLine.Метод = "DeletePosts";
NewLine.МетодПоиска = "DELETEPOSTS";
NewLine.Метод = "DeleteRecords";
NewLine.МетодПоиска = "DELETERECORDS";
NewLine.Параметр = "--filter";
NewLine.Описание = "Filters array. See GetRecordsFilterStrucutre (optional, def. val. - Empty value)";
NewLine.Область = "Orm";
@@ -426,8 +426,8 @@
NewLine = CompositionTable.Add();
NewLine.Библиотека = "postgres";
NewLine.Модуль = "OPI_PostgreSQL";
NewLine.Метод = "DeletePosts";
NewLine.МетодПоиска = "DELETEPOSTS";
NewLine.Метод = "DeleteRecords";
NewLine.МетодПоиска = "DELETERECORDS";
NewLine.Параметр = "--dbc";
NewLine.Описание = "Connection or connection string (optional, def. val. - Empty value)";
NewLine.Область = "Orm";
src/en/cli/data/Classes/internal/Classes/sqlite.os
Vendored
+6 -6
View File
@@ -249,8 +249,8 @@
NewLine = CompositionTable.Add();
NewLine.Библиотека = "sqlite";
NewLine.Модуль = "OPI_SQLite";
NewLine.Метод = "DeletePosts";
NewLine.МетодПоиска = "DELETEPOSTS";
NewLine.Метод = "DeleteRecords";
NewLine.МетодПоиска = "DELETERECORDS";
NewLine.Параметр = "--table";
NewLine.Описание = "Table name";
NewLine.Область = "Orm";
@@ -260,8 +260,8 @@
NewLine = CompositionTable.Add();
NewLine.Библиотека = "sqlite";
NewLine.Модуль = "OPI_SQLite";
NewLine.Метод = "DeletePosts";
NewLine.МетодПоиска = "DELETEPOSTS";
NewLine.Метод = "DeleteRecords";
NewLine.МетодПоиска = "DELETERECORDS";
NewLine.Параметр = "--filter";
NewLine.Описание = "Filters array. See GetRecordsFilterStrucutre (optional, def. val. - Empty value)";
NewLine.Область = "Orm";
@@ -270,8 +270,8 @@
NewLine = CompositionTable.Add();
NewLine.Библиотека = "sqlite";
NewLine.Модуль = "OPI_SQLite";
NewLine.Метод = "DeletePosts";
NewLine.МетодПоиска = "DELETEPOSTS";
NewLine.Метод = "DeleteRecords";
NewLine.МетодПоиска = "DELETERECORDS";
NewLine.Параметр = "--db";
NewLine.Описание = "Existing connection or database path (optional, def. val. - Empty value)";
NewLine.Область = "Orm";
src/ru/OInt/core/Modules/OPI_PostgreSQL.os
Vendored
+1 -1
View File
@@ -245,7 +245,7 @@
OPI_ПреобразованиеТипов.ПолучитьСтроку(База);
ТекстSQL = "SELECT pg_terminate_backend(pid)
ТекстSQL = "SELECT pg_terminate_backend(pid)
|FROM pg_stat_activity
|WHERE datname = '%1' AND pid <> pg_backend_pid();";
src/ru/OInt/tests/Modules/internal/OPI_Тесты.os
Vendored
+36 -36
View File
@@ -17409,7 +17409,7 @@
СтрокаПодключения = OPI_PostgreSQL.СформироватьСтрокуПодключения(Адрес, База, Логин, Пароль);
Соединение = OPI_PostgreSQL.ОткрытьСоединение(СтрокаПодключения);
OPI_PostgreSQL.УдалитьТаблицу("users", Соединение); // SKIP
OPI_PostgreSQL.УдалитьТаблицу("users" , Соединение); // SKIP
OPI_PostgreSQL.УдалитьТаблицу("test_data", Соединение); // SKIP
Удаление = OPI_PostgreSQL.УдалитьТаблицу("test_table", Соединение); // SKIP
OPI_ПолучениеДанныхТестов.ЗаписатьЛог(Соединение, "ВыполнитьЗапросSQL (удаление 1)", "PostgreSQL"); // SKIP
@@ -17486,15 +17486,15 @@
OPI_ПолучениеДанныхТестов.ЗаписатьЛог(Результат, "ВыполнитьЗапросSQL (Transaction)", "PostgreSQL"); // SKIP
OPI_ПолучениеДанныхТестов.Проверка_РезультатИстина(Результат); // SKIP
// SQL запрос из файла
ФайлSQL = ПараметрыФункции["SQL"]; // Двоичные данные, URL или путь к файлу
Результат = OPI_PostgreSQL.ВыполнитьЗапросSQL(ФайлSQL, , , Соединение);
OPI_ПолучениеДанныхТестов.ЗаписатьЛог(Результат, "ВыполнитьЗапросSQL (файл)", "PostgreSQL"); // SKIP
OPI_ПолучениеДанныхТестов.Проверка_РезультатИстина(Результат); // SKIP
OPI_ПолучениеДанныхТестов.Проверка_РезультатИстина(Результат); // SKIP
Закрытие = OPI_PostgreSQL.ЗакрытьСоединение(Соединение);
@@ -17808,11 +17808,11 @@
Фильтры.Добавить(СтруктураФильтра);
Количество = OPI_PostgreSQl.ПолучитьЗаписи(Таблица, , Фильтры, , , СтрокаПодключения); // SKIP
OPI_ПолучениеДанныхТестов.ЗаписатьЛог(Количество, "ОбновитьЗаписи (количество)", "PostgreSQL"); // SKIP
Количество = Количество["data"].Количество(); // SKIP
Результат = OPI_PostgreSQl.ОбновитьЗаписи(Таблица, СтруктураПолей, СтруктураФильтра, СтрокаПодключения);
Количество = OPI_PostgreSQl.ПолучитьЗаписи(Таблица, , Фильтры, , , СтрокаПодключения); // SKIP
OPI_ПолучениеДанныхТестов.ЗаписатьЛог(Количество, "ОбновитьЗаписи (количество)", "PostgreSQL"); // SKIP
Количество = Количество["data"].Количество(); // SKIP
Результат = OPI_PostgreSQl.ОбновитьЗаписи(Таблица, СтруктураПолей, СтруктураФильтра, СтрокаПодключения);
// END
@@ -17820,17 +17820,17 @@
OPI_ПолучениеДанныхТестов.Проверка_РезультатИстина(Результат);
Проверка = OPI_PostgreSQl.ПолучитьЗаписи(Таблица
, "['ip_address']"
, Фильтры, , , СтрокаПодключения);
, "['ip_address']"
, Фильтры, , , СтрокаПодключения);
OPI_ПолучениеДанныхТестов.ЗаписатьЛог(Проверка, "ОбновитьЗаписи (проверка)", "PostgreSQL");
OPI_ПолучениеДанныхТестов.Проверка_РезультатИстина(Проверка);
OPI_ПолучениеДанныхТестов.Проверка_Массив(Проверка["data"], Количество);
Для Н = 0 По Проверка["data"].ВГраница() Цикл
OPI_ПолучениеДанныхТестов.Проверка_SQLiteЗначенияПолей(Проверка["data"][Н], СтруктураПолей);
КонецЦикла;
OPI_ПолучениеДанныхТестов.Проверка_SQLiteЗначенияПолей(Проверка["data"][Н], СтруктураПолей);
КонецЦикла;
КонецПроцедуры
Процедура PostgreSQL_УдалитьЗаписи(ПараметрыФункции)
@@ -17847,7 +17847,7 @@
СтрокаПодключения = OPI_PostgreSQL.СформироватьСтрокуПодключения(Адрес, База, Логин, Пароль);
Таблица = "test_data";
Фильтры = Новый Массив;
СтруктураФильтра = Новый Структура;
@@ -17859,34 +17859,34 @@
СтруктураФильтра.Вставить("union", "AND");
Фильтры.Добавить(СтруктураФильтра);
СтруктураФильтра = Новый Структура;
СтруктураФильтра.Вставить("field", "ip_address");
СтруктураФильтра.Вставить("type" , "=");
СтруктураФильтра.Вставить("value", Новый Структура("VARCHAR", "127.0.0.1"));
СтруктураФильтра.Вставить("raw" , Ложь);
Получение = OPI_PostgreSQL.ПолучитьЗаписи(Таблица, , Фильтры, , , СтрокаПодключения); // SKIP
Результат = OPI_PostgreSQL.УдалитьЗаписи(Таблица, Фильтры, СтрокаПодключения);
// END
OPI_ПолучениеДанныхТестов.ЗаписатьЛог(Получение, "УдалитьЗаписи (получение)", "PostgreSQL");
OPI_ПолучениеДанныхТестов.Проверка_РезультатИстина(Результат);
Количество = Получение["data"].Количество();
Остаток = 100 - Количество;
// END
OPI_ПолучениеДанныхТестов.ЗаписатьЛог(Получение, "УдалитьЗаписи (получение)", "PostgreSQL");
OPI_ПолучениеДанныхТестов.Проверка_РезультатИстина(Результат);
Количество = Получение["data"].Количество();
Остаток = 100 - Количество;
OPI_ПолучениеДанныхТестов.ЗаписатьЛог(Результат, "УдалитьЗаписи", "PostgreSQL");
OPI_ПолучениеДанныхТестов.Проверка_РезультатИстина(Результат);
Результат = OPI_PostgreSQL.ПолучитьЗаписи(Таблица, , , , , СтрокаПодключения);
OPI_ПолучениеДанныхТестов.ЗаписатьЛог(Результат, "УдалитьЗаписи (проверка)", "PostgreSQL");
OPI_ПолучениеДанныхТестов.Проверка_РезультатИстина(Результат);
OPI_ПолучениеДанныхТестов.Проверка_Массив(Результат["data"], Остаток);
КонецПроцедуры
Процедура PostgreSQL_УдалитьТаблицу(ПараметрыФункции)
@@ -17911,15 +17911,15 @@
OPI_ПолучениеДанныхТестов.ЗаписатьЛог(Результат, "УдалитьТаблицу", "PostgreSQL");
OPI_ПолучениеДанныхТестов.Проверка_РезультатИстина(Результат);
База = "test_data";
Таблица = "test_data";
СтрокаПодключения = OPI_PostgreSQL.СформироватьСтрокуПодключения(Адрес, База, Логин, Пароль);
Результат = OPI_PostgreSQL.УдалитьТаблицу(Таблица, СтрокаПодключения);
База = "test_data";
Таблица = "test_data";
СтрокаПодключения = OPI_PostgreSQL.СформироватьСтрокуПодключения(Адрес, База, Логин, Пароль);
Результат = OPI_PostgreSQL.УдалитьТаблицу(Таблица, СтрокаПодключения);
OPI_ПолучениеДанныхТестов.ЗаписатьЛог(Результат, "УдалитьТаблицу (тест)", "PostgreSQL");
OPI_ПолучениеДанныхТестов.Проверка_РезультатИстина(Результат);
КонецПроцедуры
Процедура PostgreSQL_УдалитьБазуДанных(ПараметрыФункции)
@@ -18010,7 +18010,7 @@
Процедура PostgreSQL_ОтключитьВсеСоединенияБазыДанных(ПараметрыФункции)
Адрес = ПараметрыФункции["PG_IP"];
Адрес = ПараметрыФункции["PG_IP"];
Логин = "bayselonarrend";
Пароль = ПараметрыФункции["PG_Password"];
База = "testbase1";
src/ru/OInt/tools/Modules/OPI_ПолучениеДанныхТестов.os
Vendored
+2 -2
View File
@@ -2155,9 +2155,9 @@
КонецФункции
Функция ПолучитьОбщийМодуль(Знач Имя)
Модуль = Вычислить(Имя);
Возврат Модуль;
КонецФункции
src/ru/OPI/src/CommonModules/OPI_PostgreSQL/Module.bsl
+1 -1
View File
@@ -245,7 +245,7 @@
OPI_ПреобразованиеТипов.ПолучитьСтроку(База);
ТекстSQL = "SELECT pg_terminate_backend(pid)
ТекстSQL = "SELECT pg_terminate_backend(pid)
|FROM pg_stat_activity
|WHERE datname = '%1' AND pid <> pg_backend_pid();";
src/ru/OPI/src/CommonModules/OPI_Тесты/Module.bsl
Vendored
+36 -36
View File
@@ -17409,7 +17409,7 @@
СтрокаПодключения = OPI_PostgreSQL.СформироватьСтрокуПодключения(Адрес, База, Логин, Пароль);
Соединение = OPI_PostgreSQL.ОткрытьСоединение(СтрокаПодключения);
OPI_PostgreSQL.УдалитьТаблицу("users", Соединение); // SKIP
OPI_PostgreSQL.УдалитьТаблицу("users" , Соединение); // SKIP
OPI_PostgreSQL.УдалитьТаблицу("test_data", Соединение); // SKIP
Удаление = OPI_PostgreSQL.УдалитьТаблицу("test_table", Соединение); // SKIP
OPI_ПолучениеДанныхТестов.ЗаписатьЛог(Соединение, "ВыполнитьЗапросSQL (удаление 1)", "PostgreSQL"); // SKIP
@@ -17486,15 +17486,15 @@
OPI_ПолучениеДанныхТестов.ЗаписатьЛог(Результат, "ВыполнитьЗапросSQL (Transaction)", "PostgreSQL"); // SKIP
OPI_ПолучениеДанныхТестов.Проверка_РезультатИстина(Результат); // SKIP
// SQL запрос из файла
ФайлSQL = ПараметрыФункции["SQL"]; // Двоичные данные, URL или путь к файлу
Результат = OPI_PostgreSQL.ВыполнитьЗапросSQL(ФайлSQL, , , Соединение);
OPI_ПолучениеДанныхТестов.ЗаписатьЛог(Результат, "ВыполнитьЗапросSQL (файл)", "PostgreSQL"); // SKIP
OPI_ПолучениеДанныхТестов.Проверка_РезультатИстина(Результат); // SKIP
OPI_ПолучениеДанныхТестов.Проверка_РезультатИстина(Результат); // SKIP
Закрытие = OPI_PostgreSQL.ЗакрытьСоединение(Соединение);
@@ -17808,11 +17808,11 @@
Фильтры.Добавить(СтруктураФильтра);
Количество = OPI_PostgreSQl.ПолучитьЗаписи(Таблица, , Фильтры, , , СтрокаПодключения); // SKIP
OPI_ПолучениеДанныхТестов.ЗаписатьЛог(Количество, "ОбновитьЗаписи (количество)", "PostgreSQL"); // SKIP
Количество = Количество["data"].Количество(); // SKIP
Результат = OPI_PostgreSQl.ОбновитьЗаписи(Таблица, СтруктураПолей, СтруктураФильтра, СтрокаПодключения);
Количество = OPI_PostgreSQl.ПолучитьЗаписи(Таблица, , Фильтры, , , СтрокаПодключения); // SKIP
OPI_ПолучениеДанныхТестов.ЗаписатьЛог(Количество, "ОбновитьЗаписи (количество)", "PostgreSQL"); // SKIP
Количество = Количество["data"].Количество(); // SKIP
Результат = OPI_PostgreSQl.ОбновитьЗаписи(Таблица, СтруктураПолей, СтруктураФильтра, СтрокаПодключения);
// END
@@ -17820,17 +17820,17 @@
OPI_ПолучениеДанныхТестов.Проверка_РезультатИстина(Результат);
Проверка = OPI_PostgreSQl.ПолучитьЗаписи(Таблица
, "['ip_address']"
, Фильтры, , , СтрокаПодключения);
, "['ip_address']"
, Фильтры, , , СтрокаПодключения);
OPI_ПолучениеДанныхТестов.ЗаписатьЛог(Проверка, "ОбновитьЗаписи (проверка)", "PostgreSQL");
OPI_ПолучениеДанныхТестов.Проверка_РезультатИстина(Проверка);
OPI_ПолучениеДанныхТестов.Проверка_Массив(Проверка["data"], Количество);
Для Н = 0 По Проверка["data"].ВГраница() Цикл
OPI_ПолучениеДанныхТестов.Проверка_SQLiteЗначенияПолей(Проверка["data"][Н], СтруктураПолей);
КонецЦикла;
OPI_ПолучениеДанныхТестов.Проверка_SQLiteЗначенияПолей(Проверка["data"][Н], СтруктураПолей);
КонецЦикла;
КонецПроцедуры
Процедура PostgreSQL_УдалитьЗаписи(ПараметрыФункции)
@@ -17847,7 +17847,7 @@
СтрокаПодключения = OPI_PostgreSQL.СформироватьСтрокуПодключения(Адрес, База, Логин, Пароль);
Таблица = "test_data";
Фильтры = Новый Массив;
СтруктураФильтра = Новый Структура;
@@ -17859,34 +17859,34 @@
СтруктураФильтра.Вставить("union", "AND");
Фильтры.Добавить(СтруктураФильтра);
СтруктураФильтра = Новый Структура;
СтруктураФильтра.Вставить("field", "ip_address");
СтруктураФильтра.Вставить("type" , "=");
СтруктураФильтра.Вставить("value", Новый Структура("VARCHAR", "127.0.0.1"));
СтруктураФильтра.Вставить("raw" , Ложь);
Получение = OPI_PostgreSQL.ПолучитьЗаписи(Таблица, , Фильтры, , , СтрокаПодключения); // SKIP
Результат = OPI_PostgreSQL.УдалитьЗаписи(Таблица, Фильтры, СтрокаПодключения);
// END
OPI_ПолучениеДанныхТестов.ЗаписатьЛог(Получение, "УдалитьЗаписи (получение)", "PostgreSQL");
OPI_ПолучениеДанныхТестов.Проверка_РезультатИстина(Результат);
Количество = Получение["data"].Количество();
Остаток = 100 - Количество;
// END
OPI_ПолучениеДанныхТестов.ЗаписатьЛог(Получение, "УдалитьЗаписи (получение)", "PostgreSQL");
OPI_ПолучениеДанныхТестов.Проверка_РезультатИстина(Результат);
Количество = Получение["data"].Количество();
Остаток = 100 - Количество;
OPI_ПолучениеДанныхТестов.ЗаписатьЛог(Результат, "УдалитьЗаписи", "PostgreSQL");
OPI_ПолучениеДанныхТестов.Проверка_РезультатИстина(Результат);
Результат = OPI_PostgreSQL.ПолучитьЗаписи(Таблица, , , , , СтрокаПодключения);
OPI_ПолучениеДанныхТестов.ЗаписатьЛог(Результат, "УдалитьЗаписи (проверка)", "PostgreSQL");
OPI_ПолучениеДанныхТестов.Проверка_РезультатИстина(Результат);
OPI_ПолучениеДанныхТестов.Проверка_Массив(Результат["data"], Остаток);
КонецПроцедуры
Процедура PostgreSQL_УдалитьТаблицу(ПараметрыФункции)
@@ -17911,15 +17911,15 @@
OPI_ПолучениеДанныхТестов.ЗаписатьЛог(Результат, "УдалитьТаблицу", "PostgreSQL");
OPI_ПолучениеДанныхТестов.Проверка_РезультатИстина(Результат);
База = "test_data";
Таблица = "test_data";
СтрокаПодключения = OPI_PostgreSQL.СформироватьСтрокуПодключения(Адрес, База, Логин, Пароль);
Результат = OPI_PostgreSQL.УдалитьТаблицу(Таблица, СтрокаПодключения);
База = "test_data";
Таблица = "test_data";
СтрокаПодключения = OPI_PostgreSQL.СформироватьСтрокуПодключения(Адрес, База, Логин, Пароль);
Результат = OPI_PostgreSQL.УдалитьТаблицу(Таблица, СтрокаПодключения);
OPI_ПолучениеДанныхТестов.ЗаписатьЛог(Результат, "УдалитьТаблицу (тест)", "PostgreSQL");
OPI_ПолучениеДанныхТестов.Проверка_РезультатИстина(Результат);
КонецПроцедуры
Процедура PostgreSQL_УдалитьБазуДанных(ПараметрыФункции)
@@ -18010,7 +18010,7 @@
Процедура PostgreSQL_ОтключитьВсеСоединенияБазыДанных(ПараметрыФункции)
Адрес = ПараметрыФункции["PG_IP"];
Адрес = ПараметрыФункции["PG_IP"];
Логин = "bayselonarrend";
Пароль = ПараметрыФункции["PG_Password"];
База = "testbase1";