From 71463433e730496c2e3c8efb967ba5900862bf56 Mon Sep 17 00:00:00 2001 From: Eli Ribble Date: Tue, 19 May 2026 15:04:25 +0000 Subject: [PATCH] Add missing user query file --- db/query/public/user.go | 20 ++++++++++++++++++++ 1 file changed, 20 insertions(+) create mode 100644 db/query/public/user.go diff --git a/db/query/public/user.go b/db/query/public/user.go new file mode 100644 index 00000000..54199ab2 --- /dev/null +++ b/db/query/public/user.go @@ -0,0 +1,20 @@ +package public + +import ( + "context" + + //"github.com/Gleipnir-Technology/bob" + "github.com/Gleipnir-Technology/nidus-sync/db" + //"github.com/Gleipnir-Technology/nidus-sync/db/gen/nidus-sync/public/enum" + "github.com/Gleipnir-Technology/jet/postgres" + "github.com/Gleipnir-Technology/nidus-sync/db/gen/nidus-sync/public/model" + "github.com/Gleipnir-Technology/nidus-sync/db/gen/nidus-sync/public/table" +) + +func UsersFromOrganizationID(ctx context.Context, txn db.Ex, org_id int64) ([]model.User, error) { + statement := table.User.SELECT( + table.User.AllColumns, + ).FROM(table.User). + WHERE(table.User.OrganizationID.EQ(postgres.Int(org_id))) + return db.ExecuteManyTx[model.User](ctx, txn, statement) +}