24841644892

Committed 23 Apr 2026 02:44PM UTC coverage: 85.279% (-4.0%) from 89.306%

Build # 24841644892

Build Type

push

gh-ci

Committed by

web-flow

Commit Message

feat: v1.11.0 PostgreSQL compatibility and SQL feature expansion (#2090)

* Add structured audit logging with immutable audit trail

Introduces a new --audit-log flag that records all gRPC operations as
structured JSON events in immudb's tamper-proof KV store. Events are
stored under the audit: key prefix in systemdb, queryable via Scan and
verifiable via VerifiableGet. An async buffered writer ensures minimal
latency impact. Configurable event filtering (all/write/admin) via
--audit-log-events flag.

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>

* Add PostgreSQL ORM compatibility layer and verification functions

Extend the pgsql wire protocol with immudb verification functions
(immudb_state, immudb_verify_row, immudb_verify_tx, immudb_history,
immudb_tx) accessible via standard SQL SELECT statements.

Add pg_catalog resolvers (pg_attribute, pg_index, pg_constraint,
pg_type, pg_settings, pg_description) and information_schema
resolvers (tables, columns, schemata, key_column_usage) to support
ORM introspection from Django, SQLAlchemy, GORM, and ActiveRecord.

Add PostgreSQL compatibility functions: current_database,
current_schema, current_user, format_type, pg_encoding_to_char,
pg_get_expr, pg_get_constraintdef, obj_description, col_description,
has_table_privilege, has_schema_privilege, and others.

Add SHOW statement emulation for common ORM config queries and
schema-qualified name stripping for information_schema and public
schema references.

* Implement EXISTS and IN subquery support in SQL engine

Replace the previously stubbed ExistsBoolExp and InSubQueryExp
implementations with working non-correlated subquery execution.

EXISTS subqueries resolve the inner SELECT and check if any rows
are returned. IN subqueries resolve the inner SELECT, iterate the
result set, and compare each value against the outer expression.
Both support NOT variants (NOT EXISTS, NOT IN).

Correlated subqueries (referencing outer query columns) ar... (continued)

Coverage Stats

7254 of 10471 new or added lines in 124 files covered. (69.28%)

115 existing lines in 18 files now uncovered.

44599 of 52298 relevant lines covered (85.28%)

127676.6 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

85.71

/pkg/pgsql/sys/pg_attrdef.go

/*
Copyright 2026 Codenotary Inc. All rights reserved.

SPDX-License-Identifier: BUSL-1.1
you may not use this file except in compliance with the License.
You may obtain a copy of the License at

    https://mariadb.com/bsl11/

Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/

package sys

import (
        "context"

        "github.com/codenotary/immudb/embedded/sql"
)

// pg_attrdef: column-default metadata. immudb stores column
// defaults on the Column struct directly rather than as a separate
// catalog table, so there's no natural row source. Registering the
// table empty (0 rows) is still necessary because psql's `\d
// <table>` detail query JOINs pg_attrdef in a subquery to fetch
// the default expression text:
//
//        (SELECT pg_catalog.pg_get_expr(d.adbin, d.adrelid, true)
//         FROM pg_catalog.pg_attrdef d
//         WHERE d.adrelid = a.attrelid AND d.adnum = a.attnum AND a.atthasdef)
//
// Without this registration the dispatcher's allPgRefsRegistered
// marks the whole query unregistered and shunts it to the canned
// pgAdminProbe handler, which then matches the "pg_type" substring
// (from the sibling pg_collation/pg_type subquery) and returns a
// synthesized stdPgTypes row set — 23 all-NULL rows where the user
// expects their actual column metadata.
//
// The correct behaviour with an empty pg_attrdef: the subquery
// returns NULL for every row, which psql renders as a blank
// "Default" column. That's semantically correct for immudb tables
// (defaults live in the column, not in a side table).
func init() {
        sql.RegisterSystemTable(&sql.SystemTableDef{
                Name: "pg_attrdef",
                Columns: []sql.SystemTableColumn{
                        {Name: "oid", Type: sql.IntegerType},
                        {Name: "adrelid", Type: sql.IntegerType},
                        {Name: "adnum", Type: sql.IntegerType},
                        {Name: "adbin", Type: sql.VarcharType, MaxLen: 1024},
                        {Name: "adsrc", Type: sql.VarcharType, MaxLen: 1024},
                },
                PKColumn: "oid",
                Scan: func(ctx context.Context, tx *sql.SQLTx) ([]*sql.Row, error) {
                        return nil, nil
                },
        })
}

1	/*
2	Copyright 2026 Codenotary Inc. All rights reserved.
3
4	SPDX-License-Identifier: BUSL-1.1
5	you may not use this file except in compliance with the License.
6	You may obtain a copy of the License at
7
8	https://mariadb.com/bsl11/
9
10	Unless required by applicable law or agreed to in writing, software
11	distributed under the License is distributed on an "AS IS" BASIS,
12	WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13	See the License for the specific language governing permissions and
14	limitations under the License.
15	*/
16
17	package sys
18
19	import (
20	"context"
21
22	"github.com/codenotary/immudb/embedded/sql"
23	)
24
25	// pg_attrdef: column-default metadata. immudb stores column
26	// defaults on the Column struct directly rather than as a separate
27	// catalog table, so there's no natural row source. Registering the
28	// table empty (0 rows) is still necessary because psql's `\d
29	// <table>` detail query JOINs pg_attrdef in a subquery to fetch
30	// the default expression text:
31	//
32	// (SELECT pg_catalog.pg_get_expr(d.adbin, d.adrelid, true)
33	// FROM pg_catalog.pg_attrdef d
34	// WHERE d.adrelid = a.attrelid AND d.adnum = a.attnum AND a.atthasdef)
35	//
36	// Without this registration the dispatcher's allPgRefsRegistered
37	// marks the whole query unregistered and shunts it to the canned
38	// pgAdminProbe handler, which then matches the "pg_type" substring
39	// (from the sibling pg_collation/pg_type subquery) and returns a
40	// synthesized stdPgTypes row set — 23 all-NULL rows where the user
41	// expects their actual column metadata.
42	//
43	// The correct behaviour with an empty pg_attrdef: the subquery
44	// returns NULL for every row, which psql renders as a blank
45	// "Default" column. That's semantically correct for immudb tables
46	// (defaults live in the column, not in a side table).
47	func init() {	13✔
48	sql.RegisterSystemTable(&sql.SystemTableDef{	13✔
49	Name: "pg_attrdef",	13✔
50	Columns: []sql.SystemTableColumn{	13✔
51	{Name: "oid", Type: sql.IntegerType},	13✔
52	{Name: "adrelid", Type: sql.IntegerType},	13✔
53	{Name: "adnum", Type: sql.IntegerType},	13✔
54	{Name: "adbin", Type: sql.VarcharType, MaxLen: 1024},	13✔
55	{Name: "adsrc", Type: sql.VarcharType, MaxLen: 1024},	13✔
56	},	13✔
57	PKColumn: "oid",	13✔
58	Scan: func(ctx context.Context, tx sql.SQLTx) ([]sql.Row, error) {	13✔
NEW 59	return nil, nil	×
NEW 60	},	×
61	})
62	}

codenotary / immudb / 24841644892

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous