Добавил поддержку парсеровских массивов в lib/sql (соединение и ОРМ)

lib/sql/connection.p

@@ -33,8 +33,7 @@ pfClass
   ^if(!def $self.dialect){
     $self.dialect[^switch[$self.serverType]{
       ^case[mysql;mysql8;mysql57]{^pfSQLMySQLDialect::create[]}
-      ^case[pgsql]{^pfSQLPostgresDialect::create[]}
-      ^case[postgresql]{^pfSQLPostgresDialect::create[]}
+      ^case[pgsql;postgresql]{^pfSQLPostgresDialect::create[]}
       ^case[sqlite]{^pfSQLSQLiteDialect::create[]}
       ^case[DEFAULT]{^pfSQLAnsiDialect::create[]}
     }]
@@ -230,6 +229,14 @@ pfClass
   $lOptions[^self._getOptions[$lQuery;hash;$aSQLOptions;$aOptions]]
   $result[^self._processMemoryCache{^self._sql[hash]{^hash::sql{$lQuery}[$aSQLOptions]}[$lOptions]}[$lOptions]]
 
+@array[aQuery;aSQLOptions;aOptions]
+## aOptions.force — отключить кеширование в памяти
+## aOptions.cacheKey — ключ для кеширования. Если не задан, то вычисляется автоматически.
+## aOptions.log[] — запись, которую надо сделать в логе вместо текста запроса.
+  $lQuery[$aQuery]
+  $lOptions[^self._getOptions[$lQuery;array;$aSQLOptions;$aOptions]]
+  $result[^self._processMemoryCache{^self._sql[array]{^array::sql{$lQuery}[$aSQLOptions]}[$lOptions]}[$lOptions]]
+
 @file[aQuery;aSQLOptions;aOptions]
 ## aOptions.force — отключить кеширование в памяти
 ## aOptions.cacheKey — ключ для кеширования. Если не задан, то вычисляется автоматически.
@@ -353,7 +360,7 @@ pfClass
         $.results(^switch[$aType]{
           ^case[DEFAULT;void]{0}
           ^case[int;double;string;file]{1}
-          ^case[table;hash]{^eval($result)}
+          ^case[table;hash;array]{^eval($result)}
         })
         $.exception[$lException]
       ]

lib/sql/models/sql_table.p

@@ -20,6 +20,7 @@ pfClass
 ## aOptions.schema — название схемы в БД (можно не указывать)
 ## aOptions.builder
 ## aOptions.allAsTable(false) — по-умолчанию возвращать результат в виде таблицы
+## aOptions.allAsTable(false) — по-умолчанию возвращать результат в виде массива хешей
 ## aOptions.readOnlyTable(false) — модель только для чтения (методы, менящие данне, вызовут исключение)
 
 ## Следующие поля необязательны, но полезны
@@ -63,7 +64,7 @@ pfClass
   $self._skipOnUpdate[^hash::create[^if(def $aOptions.skipOnUpdate){$aOptions.skipOnUpdate}]]
   $self._skipOnSelect[^hash::create[^if(def $aOptions.skipOnSelect){$aOptions.skipOnSelect}]]
 
-  $self._defaultResultType[^if(^aOptions.allAsTable.bool(false)){table}{hash}]
+  $self._defaultResultType[^if(^aOptions.allAsTable.bool(false)){table}(^aOptions.allAsArray.bool(false)){array}{hash}]
 
   $self._defaultOrderBy[]
   $self._defaultGroupBy[]
@@ -330,6 +331,7 @@ pfClass
 ## aOptions.asTable(false) — возвращаем таблицу
 ## aOptions.asHash(false) — возвращаем хеш (ключ хеша — первичный ключ таблицы)
 ## aOptions.asHashOn[fieldName] — возвращаем хеш таблиц, ключем которого будет fieldName
+## aOptions.asArray(false) — возвращаем массив
 ## Выражения для контроля выборки (код в фигурных скобках):
 ##   aOptions.selectFieldsGroups[group1, group2] — выбрать толкьо поля с группами
 ##   aOptions.selectFields{exression} — выражение для списка полей (вместо автогенерации)
@@ -401,7 +403,10 @@ pfClass
 @aggregate[*aConds]
 ## Выборки с группировкой
 ## ^aggregate[func(expr) as alias;_fields(field1, field2 as alias2);_fields(*);_groups(group1, group2);table[<field>];conditions hash;sqlOptions]
-## aConds.asHashOn[fieldName] — возвращаем хеш таблиц, ключем которого будет fieldName
+## aOptions.asTable(false) — возвращаем таблицу
+## aOptions.asHash(false) — возвращаем хеш (ключ хеша — первичный ключ таблицы)
+## aOptions.asHashOn[fieldName] — возвращаем хеш таблиц, ключем которого будет fieldName
+## aOptions.asArray(false) — возвращаем массив
   $lConds[^self.__getAgrConds[$aConds]]
   $lResultType[^if(def $lConds.options.asHashOn){table}{^self.__getResultType[$lConds.options]}]
   $lExpression[^self.__aggregateSQLExpression[$lResultType;$lConds]]
@@ -794,6 +799,7 @@ pfClass
   $result[^switch(true){
     ^case(^aOptions.asTable.bool(false)){table}
     ^case(^aOptions.asHash.bool(false)){hash}
+    ^case(^aOptions.asArray.bool(false)){array}
     ^case[DEFAULT]{$self._defaultResultType}
   }]
 

lib/tests/unittest.p

@@ -763,6 +763,8 @@ $aException.file (${aException.lineno}:$aException.colno)]
     $.bool[math]
     $.string[string]
     $.void[string]
+    $.table[json_string]
+    $.array[json_string]
     $.hash[recursive]
     $._default[fail]
   ]
@@ -793,6 +795,7 @@ $aException.file (${aException.lineno}:$aException.colno)]
       ^if(
         ($lExpEqType eq "math" && $aActual.[$k] != $v)
         || ($lExpEqType eq "string" && $aActual.[$k] ne $v)
+        || ($lExpEqType eq "json_string" && "^json:string[$aActual.[$k]]" ne "^json:string[$v]")
       ){
         ^throw[$lExceptionType;Not equals value for "$k" key]
       }

ut/sql/sql_connection_test.p

@@ -167,6 +167,19 @@ BaseTestSQLConnection
     $.7[$.b[700]]
   ]
 
+@testArray[]
+  $lTable[^self.createTestTable[]]
+	^self.assertNotRaises[sql.execute]{
+		$lActual[^self.sut.array{select * from $lTable order by a}[$.limit(2) $.offset(5)]]
+  }
+  ^self.assertEqualsAsJSON[$lActual;
+    ^array::create[
+      $.a[6] $.b[600]
+    ][
+      $.a[7] $.b[700]
+    ]
+  ]
+
 @testString[]
   ^self.assertEq[^self.sut.string{select 'string data'};string data]