diff --git a/internal/compiler/analyze.go b/internal/compiler/analyze.go
index 739cd07993..584042f979 100644
--- a/internal/compiler/analyze.go
+++ b/internal/compiler/analyze.go
@@ -58,6 +58,8 @@ func combineAnalysis(prev *analysis, a *analyzer.Analysis) *analysis {
 	if len(prev.Columns) == len(cols) {
 		for i := range prev.Columns {
 			prev.Columns[i].DataType = cols[i].DataType
+			prev.Columns[i].IsArray = cols[i].IsArray
+			prev.Columns[i].ArrayDims = cols[i].ArrayDims
 		}
 	} else {
 		embedding := false
@@ -73,6 +75,8 @@ func combineAnalysis(prev *analysis, a *analyzer.Analysis) *analysis {
 	if len(prev.Parameters) == len(params) {
 		for i := range prev.Parameters {
 			prev.Parameters[i].Column.DataType = params[i].Column.DataType
+			prev.Parameters[i].Column.IsArray = params[i].Column.IsArray
+			prev.Parameters[i].Column.ArrayDims = params[i].Column.ArrayDims
 		}
 	} else {
 		prev.Parameters = params
diff --git a/internal/endtoend/testdata/cte_recursive_employees/issue.md b/internal/endtoend/testdata/cte_recursive_employees/issue.md
index 2bc033582e..11f5771fd8 100644
--- a/internal/endtoend/testdata/cte_recursive_employees/issue.md
+++ b/internal/endtoend/testdata/cte_recursive_employees/issue.md
@@ -1 +1,2 @@
-https://github.com/sqlc-dev/sqlc/issues/1219
\ No newline at end of file
+https://github.com/sqlc-dev/sqlc/issues/1219
+https://github.com/sqlc-dev/sqlc/issues/1912
diff --git a/internal/endtoend/testdata/cte_recursive_star/postgresql/pgx/go/query.sql.go b/internal/endtoend/testdata/cte_recursive_star/postgresql/pgx/go/query.sql.go
index d96dd07b08..357101c951 100644
--- a/internal/endtoend/testdata/cte_recursive_star/postgresql/pgx/go/query.sql.go
+++ b/internal/endtoend/testdata/cte_recursive_star/postgresql/pgx/go/query.sql.go
@@ -26,7 +26,7 @@ type GetDictTreeRow struct {
 	ParentCode string
 	Label      string
 	Value      pgtype.Text
-	Path       pgtype.Text
+	Path       []string
 	Depth      int32
 }
 
diff --git a/internal/endtoend/testdata/cte_update_multiple/issue.md b/internal/endtoend/testdata/cte_update_multiple/issue.md
new file mode 100644
index 0000000000..fc662de1ea
--- /dev/null
+++ b/internal/endtoend/testdata/cte_update_multiple/issue.md
@@ -0,0 +1 @@
+https://github.com/sqlc-dev/sqlc/issues/1916
diff --git a/internal/endtoend/testdata/cte_update_multiple/postgresql/pgx/exec.json b/internal/endtoend/testdata/cte_update_multiple/postgresql/pgx/exec.json
new file mode 100644
index 0000000000..ee1b7ecd9e
--- /dev/null
+++ b/internal/endtoend/testdata/cte_update_multiple/postgresql/pgx/exec.json
@@ -0,0 +1,3 @@
+{
+  "contexts": ["managed-db"]
+}
diff --git a/internal/endtoend/testdata/cte_update_multiple/postgresql/pgx/go/db.go b/internal/endtoend/testdata/cte_update_multiple/postgresql/pgx/go/db.go
new file mode 100644
index 0000000000..8a010ccc48
--- /dev/null
+++ b/internal/endtoend/testdata/cte_update_multiple/postgresql/pgx/go/db.go
@@ -0,0 +1,32 @@
+// Code generated by sqlc. DO NOT EDIT.
+// versions:
+//   sqlc v1.22.0
+
+package querytest
+
+import (
+	"context"
+
+	"github.com/jackc/pgx/v5"
+	"github.com/jackc/pgx/v5/pgconn"
+)
+
+type DBTX interface {
+	Exec(context.Context, string, ...interface{}) (pgconn.CommandTag, error)
+	Query(context.Context, string, ...interface{}) (pgx.Rows, error)
+	QueryRow(context.Context, string, ...interface{}) pgx.Row
+}
+
+func New(db DBTX) *Queries {
+	return &Queries{db: db}
+}
+
+type Queries struct {
+	db DBTX
+}
+
+func (q *Queries) WithTx(tx pgx.Tx) *Queries {
+	return &Queries{
+		db: tx,
+	}
+}
diff --git a/internal/endtoend/testdata/cte_update_multiple/postgresql/pgx/go/models.go b/internal/endtoend/testdata/cte_update_multiple/postgresql/pgx/go/models.go
new file mode 100644
index 0000000000..7998107846
--- /dev/null
+++ b/internal/endtoend/testdata/cte_update_multiple/postgresql/pgx/go/models.go
@@ -0,0 +1,37 @@
+// Code generated by sqlc. DO NOT EDIT.
+// versions:
+//   sqlc v1.22.0
+
+package querytest
+
+import (
+	"github.com/jackc/pgx/v5/pgtype"
+)
+
+type Address struct {
+	ID          int64
+	AddressLine string
+	Region      string
+	City        string
+	CreatedAt   pgtype.Timestamptz
+	UpdatedAt   pgtype.Timestamptz
+}
+
+type User struct {
+	ID             int64
+	Username       string
+	Email          string
+	Password       string
+	Telephone      int32
+	DefaultPayment pgtype.Int8
+	CreatedAt      pgtype.Timestamptz
+	UpdatedAt      pgtype.Timestamptz
+}
+
+type UserAddress struct {
+	UserID         int64
+	AddressID      int64
+	DefaultAddress pgtype.Int8
+	CreatedAt      pgtype.Timestamptz
+	UpdatedAt      pgtype.Timestamptz
+}
diff --git a/internal/endtoend/testdata/cte_update_multiple/postgresql/pgx/go/query.sql.go b/internal/endtoend/testdata/cte_update_multiple/postgresql/pgx/go/query.sql.go
new file mode 100644
index 0000000000..abfd049e33
--- /dev/null
+++ b/internal/endtoend/testdata/cte_update_multiple/postgresql/pgx/go/query.sql.go
@@ -0,0 +1,83 @@
+// Code generated by sqlc. DO NOT EDIT.
+// versions:
+//   sqlc v1.22.0
+// source: query.sql
+
+package querytest
+
+import (
+	"context"
+
+	"github.com/jackc/pgx/v5/pgtype"
+)
+
+const updateUserAddressWithAddress = `-- name: UpdateUserAddressWithAddress :one
+WITH t1 AS (
+    UPDATE "address" as a
+    SET
+    address_line = COALESCE($1,address_line), 
+    region = COALESCE($2,region), 
+    city= COALESCE($3,city)
+    WHERE id = COALESCE($4,id)
+    RETURNING a.id, a.address_line, a.region, a.city
+   ),
+   
+    t2 AS (
+    UPDATE "user_address"
+    SET
+    default_address = COALESCE($5,default_address)
+    WHERE
+    user_id = COALESCE($6,user_id)
+    AND address_id = COALESCE($7,address_id)
+    RETURNING user_id, address_id, default_address
+	)
+	
+SELECT 
+user_id,
+address_id,
+default_address,
+address_line,
+region,
+city From t1,t2
+`
+
+type UpdateUserAddressWithAddressParams struct {
+	AddressLine    pgtype.Text
+	Region         pgtype.Text
+	City           pgtype.Text
+	ID             pgtype.Int8
+	DefaultAddress pgtype.Int8
+	UserID         pgtype.Int8
+	AddressID      pgtype.Int8
+}
+
+type UpdateUserAddressWithAddressRow struct {
+	UserID         int64
+	AddressID      int64
+	DefaultAddress pgtype.Int8
+	AddressLine    string
+	Region         string
+	City           string
+}
+
+func (q *Queries) UpdateUserAddressWithAddress(ctx context.Context, arg UpdateUserAddressWithAddressParams) (UpdateUserAddressWithAddressRow, error) {
+	row := q.db.QueryRow(ctx, updateUserAddressWithAddress,
+		arg.AddressLine,
+		arg.Region,
+		arg.City,
+		arg.ID,
+		arg.DefaultAddress,
+		arg.UserID,
+		arg.AddressID,
+	)
+	var i UpdateUserAddressWithAddressRow
+	err := row.Scan(
+		&i.UserID,
+		&i.AddressID,
+		&i.DefaultAddress,
+		&i.AddressLine,
+		&i.Region,
+		&i.City,
+	)
+	return i, err
+}
diff --git a/internal/endtoend/testdata/cte_update_multiple/postgresql/pgx/query.sql b/internal/endtoend/testdata/cte_update_multiple/postgresql/pgx/query.sql
new file mode 100644
index 0000000000..9cb15e5b69
--- /dev/null
+++ b/internal/endtoend/testdata/cte_update_multiple/postgresql/pgx/query.sql
@@ -0,0 +1,28 @@
+-- name: UpdateUserAddressWithAddress :one
+WITH t1 AS (
+    UPDATE "address" as a
+    SET
+    address_line = COALESCE(sqlc.narg(address_line),address_line), 
+    region = COALESCE(sqlc.narg(region),region), 
+    city= COALESCE(sqlc.narg(city),city)
+    WHERE id = COALESCE(sqlc.arg(id),id)
+    RETURNING a.id, a.address_line, a.region, a.city
+   ),
+   
+    t2 AS (
+    UPDATE "user_address"
+    SET
+    default_address = COALESCE(sqlc.narg(default_address),default_address)
+    WHERE
+    user_id = COALESCE(sqlc.arg(user_id),user_id)
+    AND address_id = COALESCE(sqlc.arg(address_id),address_id)
+    RETURNING user_id, address_id, default_address
+	)
+	
+SELECT 
+user_id,
+address_id,
+default_address,
+address_line,
+region,
+city From t1,t2;
diff --git a/internal/endtoend/testdata/cte_update_multiple/postgresql/pgx/schema.sql b/internal/endtoend/testdata/cte_update_multiple/postgresql/pgx/schema.sql
new file mode 100644
index 0000000000..7ec7b1a82c
--- /dev/null
+++ b/internal/endtoend/testdata/cte_update_multiple/postgresql/pgx/schema.sql
@@ -0,0 +1,27 @@
+CREATE TABLE "user" (
+  "id" bigserial PRIMARY KEY NOT NULL,
+  "username" varchar NOT NULL,
+  "email" varchar UNIQUE NOT NULL,
+  "password" varchar NOT NULL,
+  "telephone" int NOT NULL DEFAULT 0,
+  "default_payment" bigint,
+  "created_at" timestamptz NOT NULL DEFAULT (now()),
+  "updated_at" timestamptz NOT NULL DEFAULT '0001-01-01 00:00:00Z'
+);
+
+CREATE TABLE "address" (
+  "id" bigserial PRIMARY KEY NOT NULL,
+  "address_line" varchar NOT NULL,
+  "region" varchar NOT NULL,
+  "city" varchar NOT NULL,
+  "created_at" timestamptz NOT NULL DEFAULT (now()),
+  "updated_at" timestamptz NOT NULL DEFAULT '0001-01-01 00:00:00Z'
+);
+
+CREATE TABLE "user_address" (
+  "user_id" bigint NOT NULL,
+  "address_id" bigint UNIQUE NOT NULL,
+  "default_address" bigint,
+  "created_at" timestamptz NOT NULL DEFAULT (now()),
+  "updated_at" timestamptz NOT NULL DEFAULT '0001-01-01 00:00:00Z'
+);
diff --git a/internal/endtoend/testdata/cte_update_multiple/postgresql/pgx/sqlc.yaml b/internal/endtoend/testdata/cte_update_multiple/postgresql/pgx/sqlc.yaml
new file mode 100644
index 0000000000..5dc63e3f91
--- /dev/null
+++ b/internal/endtoend/testdata/cte_update_multiple/postgresql/pgx/sqlc.yaml
@@ -0,0 +1,10 @@
+version: "2"
+sql:
+  - engine: "postgresql"
+    schema: "schema.sql"
+    queries: "query.sql"
+    gen:
+      go:
+        package: "querytest"
+        out: "go"
+        sql_package: "pgx/v5"
diff --git a/internal/endtoend/testdata/ddl_create_table_unknown_type/issue.md b/internal/endtoend/testdata/ddl_create_table_unknown_type/issue.md
new file mode 100644
index 0000000000..39b617cc6a
--- /dev/null
+++ b/internal/endtoend/testdata/ddl_create_table_unknown_type/issue.md
@@ -0,0 +1 @@
+https://github.com/sqlc-dev/sqlc/issues/1917
diff --git a/internal/endtoend/testdata/ddl_create_table_unknown_type/postgresql/pgx/exec.json b/internal/endtoend/testdata/ddl_create_table_unknown_type/postgresql/pgx/exec.json
new file mode 100644
index 0000000000..ee1b7ecd9e
--- /dev/null
+++ b/internal/endtoend/testdata/ddl_create_table_unknown_type/postgresql/pgx/exec.json
@@ -0,0 +1,3 @@
+{
+  "contexts": ["managed-db"]
+}
diff --git a/internal/endtoend/testdata/ddl_create_table_unknown_type/postgresql/pgx/query.sql b/internal/endtoend/testdata/ddl_create_table_unknown_type/postgresql/pgx/query.sql
new file mode 100644
index 0000000000..299eb45e2e
--- /dev/null
+++ b/internal/endtoend/testdata/ddl_create_table_unknown_type/postgresql/pgx/query.sql
@@ -0,0 +1,2 @@
+-- name: SelectOne :one
+SELECT 1;
diff --git a/internal/endtoend/testdata/ddl_create_table_unknown_type/postgresql/pgx/schema.sql b/internal/endtoend/testdata/ddl_create_table_unknown_type/postgresql/pgx/schema.sql
new file mode 100644
index 0000000000..70cd3cf93a
--- /dev/null
+++ b/internal/endtoend/testdata/ddl_create_table_unknown_type/postgresql/pgx/schema.sql
@@ -0,0 +1,3 @@
+CREATE TABLE test_table (
+    id STRING
+);
diff --git a/internal/endtoend/testdata/ddl_create_table_unknown_type/postgresql/pgx/sqlc.yaml b/internal/endtoend/testdata/ddl_create_table_unknown_type/postgresql/pgx/sqlc.yaml
new file mode 100644
index 0000000000..5dc63e3f91
--- /dev/null
+++ b/internal/endtoend/testdata/ddl_create_table_unknown_type/postgresql/pgx/sqlc.yaml
@@ -0,0 +1,10 @@
+version: "2"
+sql:
+  - engine: "postgresql"
+    schema: "schema.sql"
+    queries: "query.sql"
+    gen:
+      go:
+        package: "querytest"
+        out: "go"
+        sql_package: "pgx/v5"
diff --git a/internal/endtoend/testdata/ddl_create_table_unknown_type/postgresql/pgx/stderr.txt b/internal/endtoend/testdata/ddl_create_table_unknown_type/postgresql/pgx/stderr.txt
new file mode 100644
index 0000000000..2cfd3bad96
--- /dev/null
+++ b/internal/endtoend/testdata/ddl_create_table_unknown_type/postgresql/pgx/stderr.txt
@@ -0,0 +1,5 @@
+# package querytest
+query.sql:1:1: rpc error: code = FailedPrecondition desc = type "string" does not exist (42704)
+CREATE TABLE test_table (
+    id STRING
+);
diff --git a/internal/endtoend/testdata/ddl_materialized_views_invalid/issue.md b/internal/endtoend/testdata/ddl_materialized_views_invalid/issue.md
new file mode 100644
index 0000000000..21df2f08dd
--- /dev/null
+++ b/internal/endtoend/testdata/ddl_materialized_views_invalid/issue.md
@@ -0,0 +1 @@
+https://github.com/sqlc-dev/sqlc/issues/1545
diff --git a/internal/endtoend/testdata/ddl_materialized_views_invalid/postgresql/pgx/exec.json b/internal/endtoend/testdata/ddl_materialized_views_invalid/postgresql/pgx/exec.json
new file mode 100644
index 0000000000..ee1b7ecd9e
--- /dev/null
+++ b/internal/endtoend/testdata/ddl_materialized_views_invalid/postgresql/pgx/exec.json
@@ -0,0 +1,3 @@
+{
+  "contexts": ["managed-db"]
+}
diff --git a/internal/endtoend/testdata/ddl_materialized_views_invalid/postgresql/pgx/query.sql b/internal/endtoend/testdata/ddl_materialized_views_invalid/postgresql/pgx/query.sql
new file mode 100644
index 0000000000..b9fa4a4eb3
--- /dev/null
+++ b/internal/endtoend/testdata/ddl_materialized_views_invalid/postgresql/pgx/query.sql
@@ -0,0 +1,4 @@
+-- name: GetTotalEarned :one
+SELECT COALESCE(SUM(earned), 0) as total_earned
+FROM grouped_kpis
+WHERE day = @day;
diff --git a/internal/endtoend/testdata/ddl_materialized_views_invalid/postgresql/pgx/schema.sql b/internal/endtoend/testdata/ddl_materialized_views_invalid/postgresql/pgx/schema.sql
new file mode 100644
index 0000000000..d95036a96a
--- /dev/null
+++ b/internal/endtoend/testdata/ddl_materialized_views_invalid/postgresql/pgx/schema.sql
@@ -0,0 +1,9 @@
+CREATE TABLE kpis (
+  ts TIMESTAMPTZ,
+  event_id TEXT NOT NULL
+);
+
+CREATE MATERIALIZED VIEW IF NOT EXISTS grouped_kpis AS
+SELECT date_trunc('1 day', ts) as day, COUNT(*)
+FROM kpis
+GROUP BY 1;
diff --git a/internal/endtoend/testdata/ddl_materialized_views_invalid/postgresql/pgx/sqlc.yaml b/internal/endtoend/testdata/ddl_materialized_views_invalid/postgresql/pgx/sqlc.yaml
new file mode 100644
index 0000000000..5dc63e3f91
--- /dev/null
+++ b/internal/endtoend/testdata/ddl_materialized_views_invalid/postgresql/pgx/sqlc.yaml
@@ -0,0 +1,10 @@
+version: "2"
+sql:
+  - engine: "postgresql"
+    schema: "schema.sql"
+    queries: "query.sql"
+    gen:
+      go:
+        package: "querytest"
+        out: "go"
+        sql_package: "pgx/v5"
diff --git a/internal/endtoend/testdata/ddl_materialized_views_invalid/postgresql/pgx/stderr.txt b/internal/endtoend/testdata/ddl_materialized_views_invalid/postgresql/pgx/stderr.txt
new file mode 100644
index 0000000000..e79676465e
--- /dev/null
+++ b/internal/endtoend/testdata/ddl_materialized_views_invalid/postgresql/pgx/stderr.txt
@@ -0,0 +1,2 @@
+# package querytest
+query.sql:2:21: column "earned" does not exist
diff --git a/internal/endtoend/testdata/delete_using/issue.md b/internal/endtoend/testdata/delete_using/issue.md
new file mode 100644
index 0000000000..c3fc394ad0
--- /dev/null
+++ b/internal/endtoend/testdata/delete_using/issue.md
@@ -0,0 +1 @@
+https://github.com/sqlc-dev/sqlc/issues/1714
diff --git a/internal/endtoend/testdata/delete_using/postgresql/pgx/exec.json b/internal/endtoend/testdata/delete_using/postgresql/pgx/exec.json
new file mode 100644
index 0000000000..ee1b7ecd9e
--- /dev/null
+++ b/internal/endtoend/testdata/delete_using/postgresql/pgx/exec.json
@@ -0,0 +1,3 @@
+{
+  "contexts": ["managed-db"]
+}
diff --git a/internal/endtoend/testdata/delete_using/postgresql/pgx/go/db.go b/internal/endtoend/testdata/delete_using/postgresql/pgx/go/db.go
new file mode 100644
index 0000000000..8a010ccc48
--- /dev/null
+++ b/internal/endtoend/testdata/delete_using/postgresql/pgx/go/db.go
@@ -0,0 +1,32 @@
+// Code generated by sqlc. DO NOT EDIT.
+// versions:
+//   sqlc v1.22.0
+
+package querytest
+
+import (
+	"context"
+
+	"github.com/jackc/pgx/v5"
+	"github.com/jackc/pgx/v5/pgconn"
+)
+
+type DBTX interface {
+	Exec(context.Context, string, ...interface{}) (pgconn.CommandTag, error)
+	Query(context.Context, string, ...interface{}) (pgx.Rows, error)
+	QueryRow(context.Context, string, ...interface{}) pgx.Row
+}
+
+func New(db DBTX) *Queries {
+	return &Queries{db: db}
+}
+
+type Queries struct {
+	db DBTX
+}
+
+func (q *Queries) WithTx(tx pgx.Tx) *Queries {
+	return &Queries{
+		db: tx,
+	}
+}
diff --git a/internal/endtoend/testdata/delete_using/postgresql/pgx/go/models.go b/internal/endtoend/testdata/delete_using/postgresql/pgx/go/models.go
new file mode 100644
index 0000000000..2208b6fa0c
--- /dev/null
+++ b/internal/endtoend/testdata/delete_using/postgresql/pgx/go/models.go
@@ -0,0 +1,18 @@
+// Code generated by sqlc. DO NOT EDIT.
+// versions:
+//   sqlc v1.22.0
+
+package querytest
+
+import (
+	"github.com/jackc/pgx/v5/pgtype"
+)
+
+type A struct {
+	AID   pgtype.Text
+	BIDFk pgtype.Text
+}
+
+type B struct {
+	BID pgtype.Text
+}
diff --git a/internal/endtoend/testdata/delete_using/postgresql/pgx/go/query.sql.go b/internal/endtoend/testdata/delete_using/postgresql/pgx/go/query.sql.go
new file mode 100644
index 0000000000..7ebf0e694e
--- /dev/null
+++ b/internal/endtoend/testdata/delete_using/postgresql/pgx/go/query.sql.go
@@ -0,0 +1,39 @@
+// Code generated by sqlc. DO NOT EDIT.
+// versions:
+//   sqlc v1.22.0
+// source: query.sql
+
+package querytest
+
+import (
+	"context"
+
+	"github.com/jackc/pgx/v5/pgtype"
+)
+
+const getSomeDeletedNotOk = `-- name: GetSomeDeletedNotOk :many
+DELETE FROM a
+USING b
+WHERE a.b_id_fk = b.b_id
+RETURNING b.b_id
+`
+
+func (q *Queries) GetSomeDeletedNotOk(ctx context.Context) ([]pgtype.Text, error) {
+	rows, err := q.db.Query(ctx, getSomeDeletedNotOk)
+	if err != nil {
+		return nil, err
+	}
+	defer rows.Close()
+	var items []pgtype.Text
+	for rows.Next() {
+		var b_id pgtype.Text
+		if err := rows.Scan(&b_id); err != nil {
+			return nil, err
+		}
+		items = append(items, b_id)
+	}
+	if err := rows.Err(); err != nil {
+		return nil, err
+	}
+	return items, nil
+}
diff --git a/internal/endtoend/testdata/delete_using/postgresql/pgx/query.sql b/internal/endtoend/testdata/delete_using/postgresql/pgx/query.sql
new file mode 100644
index 0000000000..f660aaf95d
--- /dev/null
+++ b/internal/endtoend/testdata/delete_using/postgresql/pgx/query.sql
@@ -0,0 +1,5 @@
+-- name: GetSomeDeletedNotOk :many
+DELETE FROM a
+USING b
+WHERE a.b_id_fk = b.b_id
+RETURNING b.b_id; -- column "b_id" does not exist
diff --git a/internal/endtoend/testdata/delete_using/postgresql/pgx/schema.sql b/internal/endtoend/testdata/delete_using/postgresql/pgx/schema.sql
new file mode 100644
index 0000000000..d6380b7a5f
--- /dev/null
+++ b/internal/endtoend/testdata/delete_using/postgresql/pgx/schema.sql
@@ -0,0 +1,9 @@
+CREATE TABLE a
+(
+    a_id TEXT,
+    b_id_fk TEXT
+);
+CREATE TABLE b
+(
+    b_id TEXT
+);
diff --git a/internal/endtoend/testdata/delete_using/postgresql/pgx/sqlc.yaml b/internal/endtoend/testdata/delete_using/postgresql/pgx/sqlc.yaml
new file mode 100644
index 0000000000..5dc63e3f91
--- /dev/null
+++ b/internal/endtoend/testdata/delete_using/postgresql/pgx/sqlc.yaml
@@ -0,0 +1,10 @@
+version: "2"
+sql:
+  - engine: "postgresql"
+    schema: "schema.sql"
+    queries: "query.sql"
+    gen:
+      go:
+        package: "querytest"
+        out: "go"
+        sql_package: "pgx/v5"
diff --git a/internal/endtoend/testdata/func_return_record/issue.md b/internal/endtoend/testdata/func_return_record/issue.md
new file mode 100644
index 0000000000..56e68299aa
--- /dev/null
+++ b/internal/endtoend/testdata/func_return_record/issue.md
@@ -0,0 +1 @@
+https://github.com/sqlc-dev/sqlc/issues/1979
diff --git a/internal/endtoend/testdata/func_return_record/postgresql/pgx/exec.json b/internal/endtoend/testdata/func_return_record/postgresql/pgx/exec.json
new file mode 100644
index 0000000000..ee1b7ecd9e
--- /dev/null
+++ b/internal/endtoend/testdata/func_return_record/postgresql/pgx/exec.json
@@ -0,0 +1,3 @@
+{
+  "contexts": ["managed-db"]
+}
diff --git a/internal/endtoend/testdata/func_return_record/postgresql/pgx/go/db.go b/internal/endtoend/testdata/func_return_record/postgresql/pgx/go/db.go
new file mode 100644
index 0000000000..8a010ccc48
--- /dev/null
+++ b/internal/endtoend/testdata/func_return_record/postgresql/pgx/go/db.go
@@ -0,0 +1,32 @@
+// Code generated by sqlc. DO NOT EDIT.
+// versions:
+//   sqlc v1.22.0
+
+package querytest
+
+import (
+	"context"
+
+	"github.com/jackc/pgx/v5"
+	"github.com/jackc/pgx/v5/pgconn"
+)
+
+type DBTX interface {
+	Exec(context.Context, string, ...interface{}) (pgconn.CommandTag, error)
+	Query(context.Context, string, ...interface{}) (pgx.Rows, error)
+	QueryRow(context.Context, string, ...interface{}) pgx.Row
+}
+
+func New(db DBTX) *Queries {
+	return &Queries{db: db}
+}
+
+type Queries struct {
+	db DBTX
+}
+
+func (q *Queries) WithTx(tx pgx.Tx) *Queries {
+	return &Queries{
+		db: tx,
+	}
+}
diff --git a/internal/endtoend/testdata/func_return_record/postgresql/pgx/go/models.go b/internal/endtoend/testdata/func_return_record/postgresql/pgx/go/models.go
new file mode 100644
index 0000000000..077e702557
--- /dev/null
+++ b/internal/endtoend/testdata/func_return_record/postgresql/pgx/go/models.go
@@ -0,0 +1,11 @@
+// Code generated by sqlc. DO NOT EDIT.
+// versions:
+//   sqlc v1.22.0
+
+package querytest
+
+import ()
+
+type MyTable struct {
+	Data []byte
+}
diff --git a/internal/endtoend/testdata/func_return_record/postgresql/pgx/go/query.sql.go b/internal/endtoend/testdata/func_return_record/postgresql/pgx/go/query.sql.go
new file mode 100644
index 0000000000..0a9080f53d
--- /dev/null
+++ b/internal/endtoend/testdata/func_return_record/postgresql/pgx/go/query.sql.go
@@ -0,0 +1,30 @@
+// Code generated by sqlc. DO NOT EDIT.
+// versions:
+//   sqlc v1.22.0
+// source: query.sql
+
+package querytest
+
+import (
+	"context"
+
+	"github.com/jackc/pgx/v5/pgtype"
+)
+
+const getData = `-- name: GetData :one
+SELECT key, value
+FROM my_table, jsonb_each(data)
+LIMIT 1
+`
+
+type GetDataRow struct {
+	Key   pgtype.Text
+	Value []byte
+}
+
+func (q *Queries) GetData(ctx context.Context) (GetDataRow, error) {
+	row := q.db.QueryRow(ctx, getData)
+	var i GetDataRow
+	err := row.Scan(&i.Key, &i.Value)
+	return i, err
+}
diff --git a/internal/endtoend/testdata/func_return_record/postgresql/pgx/query.sql b/internal/endtoend/testdata/func_return_record/postgresql/pgx/query.sql
new file mode 100644
index 0000000000..c540b6ac53
--- /dev/null
+++ b/internal/endtoend/testdata/func_return_record/postgresql/pgx/query.sql
@@ -0,0 +1,4 @@
+-- name: GetData :one
+SELECT key, value
+FROM my_table, jsonb_each(data)
+LIMIT 1;
diff --git a/internal/endtoend/testdata/func_return_record/postgresql/pgx/schema.sql b/internal/endtoend/testdata/func_return_record/postgresql/pgx/schema.sql
new file mode 100644
index 0000000000..4db45f9723
--- /dev/null
+++ b/internal/endtoend/testdata/func_return_record/postgresql/pgx/schema.sql
@@ -0,0 +1,3 @@
+CREATE TABLE my_table (
+  data JSONB NOT NULL
+);
diff --git a/internal/endtoend/testdata/func_return_record/postgresql/pgx/sqlc.yaml b/internal/endtoend/testdata/func_return_record/postgresql/pgx/sqlc.yaml
new file mode 100644
index 0000000000..5dc63e3f91
--- /dev/null
+++ b/internal/endtoend/testdata/func_return_record/postgresql/pgx/sqlc.yaml
@@ -0,0 +1,10 @@
+version: "2"
+sql:
+  - engine: "postgresql"
+    schema: "schema.sql"
+    queries: "query.sql"
+    gen:
+      go:
+        package: "querytest"
+        out: "go"
+        sql_package: "pgx/v5"
diff --git a/internal/endtoend/testdata/insert_select_case/issue.md b/internal/endtoend/testdata/insert_select_case/issue.md
new file mode 100644
index 0000000000..f4090f863a
--- /dev/null
+++ b/internal/endtoend/testdata/insert_select_case/issue.md
@@ -0,0 +1 @@
+https://github.com/sqlc-dev/sqlc/issues/1646
diff --git a/internal/endtoend/testdata/insert_select_case/postgresql/pgx/exec.json b/internal/endtoend/testdata/insert_select_case/postgresql/pgx/exec.json
new file mode 100644
index 0000000000..ee1b7ecd9e
--- /dev/null
+++ b/internal/endtoend/testdata/insert_select_case/postgresql/pgx/exec.json
@@ -0,0 +1,3 @@
+{
+  "contexts": ["managed-db"]
+}
diff --git a/internal/endtoend/testdata/insert_select_case/postgresql/pgx/go/db.go b/internal/endtoend/testdata/insert_select_case/postgresql/pgx/go/db.go
new file mode 100644
index 0000000000..8a010ccc48
--- /dev/null
+++ b/internal/endtoend/testdata/insert_select_case/postgresql/pgx/go/db.go
@@ -0,0 +1,32 @@
+// Code generated by sqlc. DO NOT EDIT.
+// versions:
+//   sqlc v1.22.0
+
+package querytest
+
+import (
+	"context"
+
+	"github.com/jackc/pgx/v5"
+	"github.com/jackc/pgx/v5/pgconn"
+)
+
+type DBTX interface {
+	Exec(context.Context, string, ...interface{}) (pgconn.CommandTag, error)
+	Query(context.Context, string, ...interface{}) (pgx.Rows, error)
+	QueryRow(context.Context, string, ...interface{}) pgx.Row
+}
+
+func New(db DBTX) *Queries {
+	return &Queries{db: db}
+}
+
+type Queries struct {
+	db DBTX
+}
+
+func (q *Queries) WithTx(tx pgx.Tx) *Queries {
+	return &Queries{
+		db: tx,
+	}
+}
diff --git a/internal/endtoend/testdata/insert_select_case/postgresql/pgx/go/models.go b/internal/endtoend/testdata/insert_select_case/postgresql/pgx/go/models.go
new file mode 100644
index 0000000000..100524a307
--- /dev/null
+++ b/internal/endtoend/testdata/insert_select_case/postgresql/pgx/go/models.go
@@ -0,0 +1,14 @@
+// Code generated by sqlc. DO NOT EDIT.
+// versions:
+//   sqlc v1.22.0
+
+package querytest
+
+import (
+	"github.com/jackc/pgx/v5/pgtype"
+)
+
+type Order struct {
+	ID   pgtype.Int8
+	Name pgtype.Text
+}
diff --git a/internal/endtoend/testdata/insert_select_case/postgresql/pgx/go/query.sql.go b/internal/endtoend/testdata/insert_select_case/postgresql/pgx/go/query.sql.go
new file mode 100644
index 0000000000..722933a951
--- /dev/null
+++ b/internal/endtoend/testdata/insert_select_case/postgresql/pgx/go/query.sql.go
@@ -0,0 +1,28 @@
+// Code generated by sqlc. DO NOT EDIT.
+// versions:
+//   sqlc v1.22.0
+// source: query.sql
+
+package querytest
+
+import (
+	"context"
+
+	"github.com/jackc/pgx/v5/pgtype"
+)
+
+const insertOrders = `-- name: InsertOrders :exec
+insert into Orders (id,name)
+select id , CASE WHEN $1::BOOLEAN THEN $2 ELSE s.name END 
+from Orders s
+`
+
+type InsertOrdersParams struct {
+	NameDoUpdate pgtype.Bool
+	Name         pgtype.Text
+}
+
+func (q *Queries) InsertOrders(ctx context.Context, arg InsertOrdersParams) error {
+	_, err := q.db.Exec(ctx, insertOrders, arg.NameDoUpdate, arg.Name)
+	return err
+}
diff --git a/internal/endtoend/testdata/insert_select_case/postgresql/pgx/query.sql b/internal/endtoend/testdata/insert_select_case/postgresql/pgx/query.sql
new file mode 100644
index 0000000000..4396b7bf20
--- /dev/null
+++ b/internal/endtoend/testdata/insert_select_case/postgresql/pgx/query.sql
@@ -0,0 +1,4 @@
+-- name: InsertOrders :exec
+insert into Orders (id,name)
+select id , CASE WHEN @name_do_update::BOOLEAN THEN @name ELSE s.name END 
+from Orders s ;
diff --git a/internal/endtoend/testdata/insert_select_case/postgresql/pgx/schema.sql b/internal/endtoend/testdata/insert_select_case/postgresql/pgx/schema.sql
new file mode 100644
index 0000000000..cbc21a5b7b
--- /dev/null
+++ b/internal/endtoend/testdata/insert_select_case/postgresql/pgx/schema.sql
@@ -0,0 +1,4 @@
+CREATE TABLE orders(
+  id bigserial,
+  name text
+);
diff --git a/internal/endtoend/testdata/insert_select_case/postgresql/pgx/sqlc.yaml b/internal/endtoend/testdata/insert_select_case/postgresql/pgx/sqlc.yaml
new file mode 100644
index 0000000000..ee50c7b6e8
--- /dev/null
+++ b/internal/endtoend/testdata/insert_select_case/postgresql/pgx/sqlc.yaml
@@ -0,0 +1,12 @@
+version: "2"
+cloud:
+  project: "01HAQMMECEYQYKFJN8MP16QC41"
+sql:
+  - engine: "postgresql"
+    schema: "schema.sql"
+    queries: "query.sql"
+    gen:
+      go:
+        package: "querytest"
+        out: "go"
+        sql_package: "pgx/v5"
diff --git a/internal/endtoend/testdata/min_max_date/issue.md b/internal/endtoend/testdata/min_max_date/issue.md
new file mode 100644
index 0000000000..73083e9651
--- /dev/null
+++ b/internal/endtoend/testdata/min_max_date/issue.md
@@ -0,0 +1 @@
+https://github.com/sqlc-dev/sqlc/issues/1574
diff --git a/internal/endtoend/testdata/min_max_date/postgresql/pgx/exec.json b/internal/endtoend/testdata/min_max_date/postgresql/pgx/exec.json
new file mode 100644
index 0000000000..ee1b7ecd9e
--- /dev/null
+++ b/internal/endtoend/testdata/min_max_date/postgresql/pgx/exec.json
@@ -0,0 +1,3 @@
+{
+  "contexts": ["managed-db"]
+}
diff --git a/internal/endtoend/testdata/min_max_date/postgresql/pgx/go/db.go b/internal/endtoend/testdata/min_max_date/postgresql/pgx/go/db.go
new file mode 100644
index 0000000000..8a010ccc48
--- /dev/null
+++ b/internal/endtoend/testdata/min_max_date/postgresql/pgx/go/db.go
@@ -0,0 +1,32 @@
+// Code generated by sqlc. DO NOT EDIT.
+// versions:
+//   sqlc v1.22.0
+
+package querytest
+
+import (
+	"context"
+
+	"github.com/jackc/pgx/v5"
+	"github.com/jackc/pgx/v5/pgconn"
+)
+
+type DBTX interface {
+	Exec(context.Context, string, ...interface{}) (pgconn.CommandTag, error)
+	Query(context.Context, string, ...interface{}) (pgx.Rows, error)
+	QueryRow(context.Context, string, ...interface{}) pgx.Row
+}
+
+func New(db DBTX) *Queries {
+	return &Queries{db: db}
+}
+
+type Queries struct {
+	db DBTX
+}
+
+func (q *Queries) WithTx(tx pgx.Tx) *Queries {
+	return &Queries{
+		db: tx,
+	}
+}
diff --git a/internal/endtoend/testdata/min_max_date/postgresql/pgx/go/models.go b/internal/endtoend/testdata/min_max_date/postgresql/pgx/go/models.go
new file mode 100644
index 0000000000..19ec509ddb
--- /dev/null
+++ b/internal/endtoend/testdata/min_max_date/postgresql/pgx/go/models.go
@@ -0,0 +1,14 @@
+// Code generated by sqlc. DO NOT EDIT.
+// versions:
+//   sqlc v1.22.0
+
+package querytest
+
+import (
+	"github.com/jackc/pgx/v5/pgtype"
+)
+
+type Activity struct {
+	AccountID int64
+	EventTime pgtype.Timestamptz
+}
diff --git a/internal/endtoend/testdata/min_max_date/postgresql/pgx/go/query.sql.go b/internal/endtoend/testdata/min_max_date/postgresql/pgx/go/query.sql.go
new file mode 100644
index 0000000000..df0bfad701
--- /dev/null
+++ b/internal/endtoend/testdata/min_max_date/postgresql/pgx/go/query.sql.go
@@ -0,0 +1,33 @@
+// Code generated by sqlc. DO NOT EDIT.
+// versions:
+//   sqlc v1.22.0
+// source: query.sql
+
+package querytest
+
+import (
+	"context"
+
+	"github.com/jackc/pgx/v5/pgtype"
+)
+
+const activityStats = `-- name: ActivityStats :one
+SELECT COUNT(*) as NumOfActivities,
+        MIN(event_time) as MinDate, 
+        MAX(event_time) as MaxDate 
+FROM activities 
+WHERE account_id = $1
+`
+
+type ActivityStatsRow struct {
+	Numofactivities int64
+	Mindate         pgtype.Timestamptz
+	Maxdate         pgtype.Timestamptz
+}
+
+func (q *Queries) ActivityStats(ctx context.Context, accountID int64) (ActivityStatsRow, error) {
+	row := q.db.QueryRow(ctx, activityStats, accountID)
+	var i ActivityStatsRow
+	err := row.Scan(&i.Numofactivities, &i.Mindate, &i.Maxdate)
+	return i, err
+}
diff --git a/internal/endtoend/testdata/min_max_date/postgresql/pgx/query.sql b/internal/endtoend/testdata/min_max_date/postgresql/pgx/query.sql
new file mode 100644
index 0000000000..19909d0c88
--- /dev/null
+++ b/internal/endtoend/testdata/min_max_date/postgresql/pgx/query.sql
@@ -0,0 +1,6 @@
+-- name: ActivityStats :one
+SELECT COUNT(*) as NumOfActivities,
+        MIN(event_time) as MinDate, 
+        MAX(event_time) as MaxDate 
+FROM activities 
+WHERE account_id = $1;
diff --git a/internal/endtoend/testdata/min_max_date/postgresql/pgx/schema.sql b/internal/endtoend/testdata/min_max_date/postgresql/pgx/schema.sql
new file mode 100644
index 0000000000..c75fe28fbd
--- /dev/null
+++ b/internal/endtoend/testdata/min_max_date/postgresql/pgx/schema.sql
@@ -0,0 +1,4 @@
+CREATE TABLE activities (
+    account_id BIGINT NOT NULL,
+    event_time TIMESTAMP WITH TIME ZONE NOT NULL
+);
diff --git a/internal/endtoend/testdata/min_max_date/postgresql/pgx/sqlc.yaml b/internal/endtoend/testdata/min_max_date/postgresql/pgx/sqlc.yaml
new file mode 100644
index 0000000000..5dc63e3f91
--- /dev/null
+++ b/internal/endtoend/testdata/min_max_date/postgresql/pgx/sqlc.yaml
@@ -0,0 +1,10 @@
+version: "2"
+sql:
+  - engine: "postgresql"
+    schema: "schema.sql"
+    queries: "query.sql"
+    gen:
+      go:
+        package: "querytest"
+        out: "go"
+        sql_package: "pgx/v5"
diff --git a/internal/endtoend/testdata/select_sequence/issue.md b/internal/endtoend/testdata/select_sequence/issue.md
new file mode 100644
index 0000000000..38c550fe19
--- /dev/null
+++ b/internal/endtoend/testdata/select_sequence/issue.md
@@ -0,0 +1 @@
+https://github.com/sqlc-dev/sqlc/issues/1634
diff --git a/internal/endtoend/testdata/select_sequence/postgresql/pgx/exec.json b/internal/endtoend/testdata/select_sequence/postgresql/pgx/exec.json
new file mode 100644
index 0000000000..ee1b7ecd9e
--- /dev/null
+++ b/internal/endtoend/testdata/select_sequence/postgresql/pgx/exec.json
@@ -0,0 +1,3 @@
+{
+  "contexts": ["managed-db"]
+}
diff --git a/internal/endtoend/testdata/select_sequence/postgresql/pgx/go/db.go b/internal/endtoend/testdata/select_sequence/postgresql/pgx/go/db.go
new file mode 100644
index 0000000000..8a010ccc48
--- /dev/null
+++ b/internal/endtoend/testdata/select_sequence/postgresql/pgx/go/db.go
@@ -0,0 +1,32 @@
+// Code generated by sqlc. DO NOT EDIT.
+// versions:
+//   sqlc v1.22.0
+
+package querytest
+
+import (
+	"context"
+
+	"github.com/jackc/pgx/v5"
+	"github.com/jackc/pgx/v5/pgconn"
+)
+
+type DBTX interface {
+	Exec(context.Context, string, ...interface{}) (pgconn.CommandTag, error)
+	Query(context.Context, string, ...interface{}) (pgx.Rows, error)
+	QueryRow(context.Context, string, ...interface{}) pgx.Row
+}
+
+func New(db DBTX) *Queries {
+	return &Queries{db: db}
+}
+
+type Queries struct {
+	db DBTX
+}
+
+func (q *Queries) WithTx(tx pgx.Tx) *Queries {
+	return &Queries{
+		db: tx,
+	}
+}
diff --git a/internal/endtoend/testdata/select_sequence/postgresql/pgx/go/models.go b/internal/endtoend/testdata/select_sequence/postgresql/pgx/go/models.go
new file mode 100644
index 0000000000..172574ab22
--- /dev/null
+++ b/internal/endtoend/testdata/select_sequence/postgresql/pgx/go/models.go
@@ -0,0 +1,7 @@
+// Code generated by sqlc. DO NOT EDIT.
+// versions:
+//   sqlc v1.22.0
+
+package querytest
+
+import ()
diff --git a/internal/endtoend/testdata/select_sequence/postgresql/pgx/go/query.sql.go b/internal/endtoend/testdata/select_sequence/postgresql/pgx/go/query.sql.go
new file mode 100644
index 0000000000..430d6b49a9
--- /dev/null
+++ b/internal/endtoend/testdata/select_sequence/postgresql/pgx/go/query.sql.go
@@ -0,0 +1,21 @@
+// Code generated by sqlc. DO NOT EDIT.
+// versions:
+//   sqlc v1.22.0
+// source: query.sql
+
+package querytest
+
+import (
+	"context"
+)
+
+const getLastValue = `-- name: GetLastValue :one
+SELECT last_value FROM my_sequence
+`
+
+func (q *Queries) GetLastValue(ctx context.Context) (int64, error) {
+	row := q.db.QueryRow(ctx, getLastValue)
+	var last_value int64
+	err := row.Scan(&last_value)
+	return last_value, err
+}
diff --git a/internal/endtoend/testdata/select_sequence/postgresql/pgx/query.sql b/internal/endtoend/testdata/select_sequence/postgresql/pgx/query.sql
new file mode 100644
index 0000000000..82cc9b0a5c
--- /dev/null
+++ b/internal/endtoend/testdata/select_sequence/postgresql/pgx/query.sql
@@ -0,0 +1,2 @@
+-- name: GetLastValue :one
+SELECT last_value FROM my_sequence;
diff --git a/internal/endtoend/testdata/select_sequence/postgresql/pgx/schema.sql b/internal/endtoend/testdata/select_sequence/postgresql/pgx/schema.sql
new file mode 100644
index 0000000000..94a6932f80
--- /dev/null
+++ b/internal/endtoend/testdata/select_sequence/postgresql/pgx/schema.sql
@@ -0,0 +1,6 @@
+CREATE SEQUENCE public.my_sequence
+    START WITH 1
+    INCREMENT BY 1
+    NO MINVALUE
+    NO MAXVALUE
+    CACHE 1;
diff --git a/internal/endtoend/testdata/select_sequence/postgresql/pgx/sqlc.yaml b/internal/endtoend/testdata/select_sequence/postgresql/pgx/sqlc.yaml
new file mode 100644
index 0000000000..5dc63e3f91
--- /dev/null
+++ b/internal/endtoend/testdata/select_sequence/postgresql/pgx/sqlc.yaml
@@ -0,0 +1,10 @@
+version: "2"
+sql:
+  - engine: "postgresql"
+    schema: "schema.sql"
+    queries: "query.sql"
+    gen:
+      go:
+        package: "querytest"
+        out: "go"
+        sql_package: "pgx/v5"
diff --git a/internal/endtoend/testdata/select_subquery_alias/issue.md b/internal/endtoend/testdata/select_subquery_alias/issue.md
new file mode 100644
index 0000000000..1f15e67216
--- /dev/null
+++ b/internal/endtoend/testdata/select_subquery_alias/issue.md
@@ -0,0 +1 @@
+https://github.com/sqlc-dev/sqlc/issues/1990
diff --git a/internal/endtoend/testdata/select_subquery_alias/postgresql/pgx/exec.json b/internal/endtoend/testdata/select_subquery_alias/postgresql/pgx/exec.json
new file mode 100644
index 0000000000..ee1b7ecd9e
--- /dev/null
+++ b/internal/endtoend/testdata/select_subquery_alias/postgresql/pgx/exec.json
@@ -0,0 +1,3 @@
+{
+  "contexts": ["managed-db"]
+}
diff --git a/internal/endtoend/testdata/select_subquery_alias/postgresql/pgx/go/db.go b/internal/endtoend/testdata/select_subquery_alias/postgresql/pgx/go/db.go
new file mode 100644
index 0000000000..8a010ccc48
--- /dev/null
+++ b/internal/endtoend/testdata/select_subquery_alias/postgresql/pgx/go/db.go
@@ -0,0 +1,32 @@
+// Code generated by sqlc. DO NOT EDIT.
+// versions:
+//   sqlc v1.22.0
+
+package querytest
+
+import (
+	"context"
+
+	"github.com/jackc/pgx/v5"
+	"github.com/jackc/pgx/v5/pgconn"
+)
+
+type DBTX interface {
+	Exec(context.Context, string, ...interface{}) (pgconn.CommandTag, error)
+	Query(context.Context, string, ...interface{}) (pgx.Rows, error)
+	QueryRow(context.Context, string, ...interface{}) pgx.Row
+}
+
+func New(db DBTX) *Queries {
+	return &Queries{db: db}
+}
+
+type Queries struct {
+	db DBTX
+}
+
+func (q *Queries) WithTx(tx pgx.Tx) *Queries {
+	return &Queries{
+		db: tx,
+	}
+}
diff --git a/internal/endtoend/testdata/select_subquery_alias/postgresql/pgx/go/models.go b/internal/endtoend/testdata/select_subquery_alias/postgresql/pgx/go/models.go
new file mode 100644
index 0000000000..14f6a8d25b
--- /dev/null
+++ b/internal/endtoend/testdata/select_subquery_alias/postgresql/pgx/go/models.go
@@ -0,0 +1,16 @@
+// Code generated by sqlc. DO NOT EDIT.
+// versions:
+//   sqlc v1.22.0
+
+package querytest
+
+import (
+	"github.com/jackc/pgx/v5/pgtype"
+)
+
+type Wallet struct {
+	ID      int64
+	Address string
+	Type    string
+	Balance pgtype.Numeric
+}
diff --git a/internal/endtoend/testdata/select_subquery_alias/postgresql/pgx/go/query.sql.go b/internal/endtoend/testdata/select_subquery_alias/postgresql/pgx/go/query.sql.go
new file mode 100644
index 0000000000..975dbbb9ed
--- /dev/null
+++ b/internal/endtoend/testdata/select_subquery_alias/postgresql/pgx/go/query.sql.go
@@ -0,0 +1,61 @@
+// Code generated by sqlc. DO NOT EDIT.
+// versions:
+//   sqlc v1.22.0
+// source: query.sql
+
+package querytest
+
+import (
+	"context"
+
+	"github.com/jackc/pgx/v5/pgtype"
+)
+
+const findWallets = `-- name: FindWallets :many
+select id, address, balance, total_balance from 
+(
+	select id, address, balance,
+	  sum(balance) over (order by balance desc rows between unbounded preceding and current row) as total_balance,
+	  sum(balance) over (order by balance desc rows between unbounded preceding and current row) - balance as last_balance
+	from wallets
+	where type=$1
+) amounts
+where amounts.last_balance < $2
+`
+
+type FindWalletsParams struct {
+	Column1 pgtype.Text
+	Column2 pgtype.Numeric
+}
+
+type FindWalletsRow struct {
+	ID           int64
+	Address      string
+	Balance      pgtype.Numeric
+	TotalBalance pgtype.Numeric
+}
+
+func (q *Queries) FindWallets(ctx context.Context, arg FindWalletsParams) ([]FindWalletsRow, error) {
+	rows, err := q.db.Query(ctx, findWallets, arg.Column1, arg.Column2)
+	if err != nil {
+		return nil, err
+	}
+	defer rows.Close()
+	var items []FindWalletsRow
+	for rows.Next() {
+		var i FindWalletsRow
+		if err := rows.Scan(
+			&i.ID,
+			&i.Address,
+			&i.Balance,
+			&i.TotalBalance,
+		); err != nil {
+			return nil, err
+		}
+		items = append(items, i)
+	}
+	if err := rows.Err(); err != nil {
+		return nil, err
+	}
+	return items, nil
+}
diff --git a/internal/endtoend/testdata/select_subquery_alias/postgresql/pgx/query.sql b/internal/endtoend/testdata/select_subquery_alias/postgresql/pgx/query.sql
new file mode 100644
index 0000000000..b3412234c9
--- /dev/null
+++ b/internal/endtoend/testdata/select_subquery_alias/postgresql/pgx/query.sql
@@ -0,0 +1,10 @@
+-- name: FindWallets :many
+select id, address, balance, total_balance from 
+(
+	select id, address, balance,
+	  sum(balance) over (order by balance desc rows between unbounded preceding and current row) as total_balance,
+	  sum(balance) over (order by balance desc rows between unbounded preceding and current row) - balance as last_balance
+	from wallets
+	where type=$1
+) amounts
+where amounts.last_balance < $2;
diff --git a/internal/endtoend/testdata/select_subquery_alias/postgresql/pgx/schema.sql b/internal/endtoend/testdata/select_subquery_alias/postgresql/pgx/schema.sql
new file mode 100644
index 0000000000..275a65e104
--- /dev/null
+++ b/internal/endtoend/testdata/select_subquery_alias/postgresql/pgx/schema.sql
@@ -0,0 +1,7 @@
+CREATE TABLE IF NOT EXISTS wallets
+(
+    id BIGSERIAL PRIMARY KEY,
+    address VARCHAR(44) NOT NULL,
+    type VARCHAR(44) NOT NULL,
+    balance DECIMAL(32, 18) NULL
+);
diff --git a/internal/endtoend/testdata/select_subquery_alias/postgresql/pgx/sqlc.yaml b/internal/endtoend/testdata/select_subquery_alias/postgresql/pgx/sqlc.yaml
new file mode 100644
index 0000000000..5dc63e3f91
--- /dev/null
+++ b/internal/endtoend/testdata/select_subquery_alias/postgresql/pgx/sqlc.yaml
@@ -0,0 +1,10 @@
+version: "2"
+sql:
+  - engine: "postgresql"
+    schema: "schema.sql"
+    queries: "query.sql"
+    gen:
+      go:
+        package: "querytest"
+        out: "go"
+        sql_package: "pgx/v5"
diff --git a/internal/endtoend/testdata/star_expansion_series/issue.md b/internal/endtoend/testdata/star_expansion_series/issue.md
new file mode 100644
index 0000000000..72e3e3aa9f
--- /dev/null
+++ b/internal/endtoend/testdata/star_expansion_series/issue.md
@@ -0,0 +1 @@
+https://github.com/sqlc-dev/sqlc/issues/1995
diff --git a/internal/endtoend/testdata/star_expansion_series/postgresql/pgx/go/db.go b/internal/endtoend/testdata/star_expansion_series/postgresql/pgx/go/db.go
new file mode 100644
index 0000000000..8a010ccc48
--- /dev/null
+++ b/internal/endtoend/testdata/star_expansion_series/postgresql/pgx/go/db.go
@@ -0,0 +1,32 @@
+// Code generated by sqlc. DO NOT EDIT.
+// versions:
+//   sqlc v1.22.0
+
+package querytest
+
+import (
+	"context"
+
+	"github.com/jackc/pgx/v5"
+	"github.com/jackc/pgx/v5/pgconn"
+)
+
+type DBTX interface {
+	Exec(context.Context, string, ...interface{}) (pgconn.CommandTag, error)
+	Query(context.Context, string, ...interface{}) (pgx.Rows, error)
+	QueryRow(context.Context, string, ...interface{}) pgx.Row
+}
+
+func New(db DBTX) *Queries {
+	return &Queries{db: db}
+}
+
+type Queries struct {
+	db DBTX
+}
+
+func (q *Queries) WithTx(tx pgx.Tx) *Queries {
+	return &Queries{
+		db: tx,
+	}
+}
diff --git a/internal/endtoend/testdata/star_expansion_series/postgresql/pgx/go/models.go b/internal/endtoend/testdata/star_expansion_series/postgresql/pgx/go/models.go
new file mode 100644
index 0000000000..31b21050ae
--- /dev/null
+++ b/internal/endtoend/testdata/star_expansion_series/postgresql/pgx/go/models.go
@@ -0,0 +1,13 @@
+// Code generated by sqlc. DO NOT EDIT.
+// versions:
+//   sqlc v1.22.0
+
+package querytest
+
+import (
+	"github.com/jackc/pgx/v5/pgtype"
+)
+
+type Alertreport struct {
+	Eventdate pgtype.Date
+}
diff --git a/internal/endtoend/testdata/star_expansion_series/postgresql/pgx/go/query.sql.go b/internal/endtoend/testdata/star_expansion_series/postgresql/pgx/go/query.sql.go
new file mode 100644
index 0000000000..e82562c5e5
--- /dev/null
+++ b/internal/endtoend/testdata/star_expansion_series/postgresql/pgx/go/query.sql.go
@@ -0,0 +1,56 @@
+// Code generated by sqlc. DO NOT EDIT.
+// versions:
+//   sqlc v1.22.0
+// source: query.sql
+
+package querytest
+
+import (
+	"context"
+
+	"github.com/jackc/pgx/v5/pgtype"
+)
+
+const countAlertReportBy = `-- name: CountAlertReportBy :many
+select DATE_TRUNC($1,ts)::text as datetime,coalesce(count,0) as count from 
+(
+    SELECT  DATE_TRUNC($1,eventdate) as hr ,count(*)
+    FROM    alertreport
+    where eventdate between $2 and $3
+    GROUP BY   1
+) AS cnt 
+right outer join ( SELECT ts FROM generate_series ( $2, $3, CONCAT('1 ',$1)::interval) AS ts ) as dte
+on DATE_TRUNC($1, ts ) = cnt.hr 
+order by 1 asc
+`
+
+type CountAlertReportByParams struct {
+	DateTrunc   string
+	Eventdate   pgtype.Date
+	Eventdate_2 pgtype.Date
+}
+
+type CountAlertReportByRow struct {
+	Datetime string
+	Count    int64
+}
+
+func (q *Queries) CountAlertReportBy(ctx context.Context, arg CountAlertReportByParams) ([]CountAlertReportByRow, error) {
+	rows, err := q.db.Query(ctx, countAlertReportBy, arg.DateTrunc, arg.Eventdate, arg.Eventdate_2)
+	if err != nil {
+		return nil, err
+	}
+	defer rows.Close()
+	var items []CountAlertReportByRow
+	for rows.Next() {
+		var i CountAlertReportByRow
+		if err := rows.Scan(&i.Datetime, &i.Count); err != nil {
+			return nil, err
+		}
+		items = append(items, i)
+	}
+	if err := rows.Err(); err != nil {
+		return nil, err
+	}
+	return items, nil
+}
diff --git a/internal/endtoend/testdata/star_expansion_series/postgresql/pgx/query.sql b/internal/endtoend/testdata/star_expansion_series/postgresql/pgx/query.sql
new file mode 100644
index 0000000000..df13ae9a96
--- /dev/null
+++ b/internal/endtoend/testdata/star_expansion_series/postgresql/pgx/query.sql
@@ -0,0 +1,11 @@
+-- name: CountAlertReportBy :many
+select DATE_TRUNC($1,ts)::text as datetime,coalesce(count,0) as count from 
+(
+    SELECT  DATE_TRUNC($1,eventdate) as hr ,count(*)
+    FROM    alertreport
+    where eventdate between $2 and $3
+    GROUP BY   1
+) AS cnt 
+right outer join ( SELECT * FROM generate_series ( $2, $3, CONCAT('1 ',$1)::interval) AS ts ) as dte
+on DATE_TRUNC($1, ts ) = cnt.hr 
+order by 1 asc;
diff --git a/internal/endtoend/testdata/star_expansion_series/postgresql/pgx/schema.sql b/internal/endtoend/testdata/star_expansion_series/postgresql/pgx/schema.sql
new file mode 100644
index 0000000000..533757a462
--- /dev/null
+++ b/internal/endtoend/testdata/star_expansion_series/postgresql/pgx/schema.sql
@@ -0,0 +1,3 @@
+CREATE TABLE alertreport (
+  eventdate date
+);
diff --git a/internal/endtoend/testdata/star_expansion_series/postgresql/pgx/sqlc.yaml b/internal/endtoend/testdata/star_expansion_series/postgresql/pgx/sqlc.yaml
new file mode 100644
index 0000000000..2f12715923
--- /dev/null
+++ b/internal/endtoend/testdata/star_expansion_series/postgresql/pgx/sqlc.yaml
@@ -0,0 +1,14 @@
+version: "2"
+cloud:
+  project: "01HAQMMECEYQYKFJN8MP16QC41"
+sql:
+  - engine: "postgresql"
+    schema: "schema.sql"
+    queries: "query.sql"
+    gen:
+      go:
+        package: "querytest"
+        out: "go"
+        sql_package: "pgx/v5"
+    database:
+      managed: true
diff --git a/internal/endtoend/testdata/update_array_index/issue.md b/internal/endtoend/testdata/update_array_index/issue.md
new file mode 100644
index 0000000000..d86fb5d2a4
--- /dev/null
+++ b/internal/endtoend/testdata/update_array_index/issue.md
@@ -0,0 +1 @@
+https://github.com/sqlc-dev/sqlc/issues/1532
diff --git a/internal/endtoend/testdata/update_array_index/postgresql/pgx/exec.json b/internal/endtoend/testdata/update_array_index/postgresql/pgx/exec.json
new file mode 100644
index 0000000000..ee1b7ecd9e
--- /dev/null
+++ b/internal/endtoend/testdata/update_array_index/postgresql/pgx/exec.json
@@ -0,0 +1,3 @@
+{
+  "contexts": ["managed-db"]
+}
diff --git a/internal/endtoend/testdata/update_array_index/postgresql/pgx/go/db.go b/internal/endtoend/testdata/update_array_index/postgresql/pgx/go/db.go
new file mode 100644
index 0000000000..8a010ccc48
--- /dev/null
+++ b/internal/endtoend/testdata/update_array_index/postgresql/pgx/go/db.go
@@ -0,0 +1,32 @@
+// Code generated by sqlc. DO NOT EDIT.
+// versions:
+//   sqlc v1.22.0
+
+package querytest
+
+import (
+	"context"
+
+	"github.com/jackc/pgx/v5"
+	"github.com/jackc/pgx/v5/pgconn"
+)
+
+type DBTX interface {
+	Exec(context.Context, string, ...interface{}) (pgconn.CommandTag, error)
+	Query(context.Context, string, ...interface{}) (pgx.Rows, error)
+	QueryRow(context.Context, string, ...interface{}) pgx.Row
+}
+
+func New(db DBTX) *Queries {
+	return &Queries{db: db}
+}
+
+type Queries struct {
+	db DBTX
+}
+
+func (q *Queries) WithTx(tx pgx.Tx) *Queries {
+	return &Queries{
+		db: tx,
+	}
+}
diff --git a/internal/endtoend/testdata/update_array_index/postgresql/pgx/go/models.go b/internal/endtoend/testdata/update_array_index/postgresql/pgx/go/models.go
new file mode 100644
index 0000000000..8ce25599b5
--- /dev/null
+++ b/internal/endtoend/testdata/update_array_index/postgresql/pgx/go/models.go
@@ -0,0 +1,12 @@
+// Code generated by sqlc. DO NOT EDIT.
+// versions:
+//   sqlc v1.22.0
+
+package querytest
+
+import ()
+
+type Author struct {
+	ID    int64
+	Names []string
+}
diff --git a/internal/endtoend/testdata/update_array_index/postgresql/pgx/go/query.sql.go b/internal/endtoend/testdata/update_array_index/postgresql/pgx/go/query.sql.go
new file mode 100644
index 0000000000..f51cedfd00
--- /dev/null
+++ b/internal/endtoend/testdata/update_array_index/postgresql/pgx/go/query.sql.go
@@ -0,0 +1,30 @@
+// Code generated by sqlc. DO NOT EDIT.
+// versions:
+//   sqlc v1.22.0
+// source: query.sql
+
+package querytest
+
+import (
+	"context"
+)
+
+const updateAuthor = `-- name: UpdateAuthor :one
+update authors
+set names[$1] = $2
+where id=$3
+RETURNING id, names
+`
+
+type UpdateAuthorParams struct {
+	Names   int32
+	Names_2 string
+	ID      int64
+}
+
+func (q *Queries) UpdateAuthor(ctx context.Context, arg UpdateAuthorParams) (Author, error) {
+	row := q.db.QueryRow(ctx, updateAuthor, arg.Names, arg.Names_2, arg.ID)
+	var i Author
+	err := row.Scan(&i.ID, &i.Names)
+	return i, err
+}
diff --git a/internal/endtoend/testdata/update_array_index/postgresql/pgx/query.sql b/internal/endtoend/testdata/update_array_index/postgresql/pgx/query.sql
new file mode 100644
index 0000000000..32b4e9c148
--- /dev/null
+++ b/internal/endtoend/testdata/update_array_index/postgresql/pgx/query.sql
@@ -0,0 +1,5 @@
+-- name: UpdateAuthor :one
+update authors
+set names[$1] = $2
+where id=$3
+RETURNING *;
diff --git a/internal/endtoend/testdata/update_array_index/postgresql/pgx/schema.sql b/internal/endtoend/testdata/update_array_index/postgresql/pgx/schema.sql
new file mode 100644
index 0000000000..286ab791fa
--- /dev/null
+++ b/internal/endtoend/testdata/update_array_index/postgresql/pgx/schema.sql
@@ -0,0 +1,4 @@
+CREATE TABLE authors (
+  id    BIGSERIAL PRIMARY KEY,
+  names text[]    NOT NULL
+);
diff --git a/internal/endtoend/testdata/update_array_index/postgresql/pgx/sqlc.yaml b/internal/endtoend/testdata/update_array_index/postgresql/pgx/sqlc.yaml
new file mode 100644
index 0000000000..5dc63e3f91
--- /dev/null
+++ b/internal/endtoend/testdata/update_array_index/postgresql/pgx/sqlc.yaml
@@ -0,0 +1,10 @@
+version: "2"
+sql:
+  - engine: "postgresql"
+    schema: "schema.sql"
+    queries: "query.sql"
+    gen:
+      go:
+        package: "querytest"
+        out: "go"
+        sql_package: "pgx/v5"