raw query

dialect/psql/delete.go

@@ -1,10 +1,19 @@
 package psql
 
 import (
+	"github.com/rrgmc/litsql"
 	"github.com/rrgmc/litsql/dialect/psql/tag"
 	"github.com/rrgmc/litsql/internal/idm"
 )
 
 func Delete(mods ...DeleteMod) DeleteQuery {
 	return idm.Delete[tag.DeleteTag](Dialect, mods...)
 }
+
+func DeleteRaw(rawQuery string, args ...any) DeleteQuery {
+	return Delete(idm.RawQuery[tag.DeleteTag](rawQuery, args...))
+}
+
+func DeleteRawExpr(e litsql.Expression) DeleteQuery {
+	return Delete(idm.RawQueryExpr[tag.DeleteTag](e))
+}

dialect/psql/delete_test.go

@@ -19,3 +19,12 @@ func TestDelete(t *testing.T) {
 	assert.Assert(t, queryStr != "")
 	assert.Assert(t, len(params) == 0)
 }
+
+func TestDeleteRaw(t *testing.T) {
+	query := psql.DeleteRaw("delete * from users where id = ?", 12, 15)
+	queryStr, params, err := query.Build()
+
+	assert.NilError(t, err)
+	assert.Equal(t, "delete * from users where id = ?", queryStr)
+	assert.DeepEqual(t, []any{12, 15}, params)
+}

dialect/psql/insert.go

@@ -1,10 +1,20 @@
 package psql
 
 import (
+	"github.com/rrgmc/litsql"
 	"github.com/rrgmc/litsql/dialect/psql/tag"
 	"github.com/rrgmc/litsql/internal/iim"
+	"github.com/rrgmc/litsql/internal/ism"
 )
 
 func Insert(mods ...InsertMod) InsertQuery {
 	return iim.Insert[tag.InsertTag](Dialect, mods...)
 }
+
+func InsertRaw(rawQuery string, args ...any) InsertQuery {
+	return Insert(ism.RawQuery[tag.InsertTag](rawQuery, args...))
+}
+
+func InsertRawExpr(e litsql.Expression) InsertQuery {
+	return Insert(ism.RawQueryExpr[tag.InsertTag](e))
+}

dialect/psql/insert_test.go

@@ -19,3 +19,12 @@ func TestInsert(t *testing.T) {
 	assert.Assert(t, queryStr != "")
 	assert.Assert(t, len(params) == 0)
 }
+
+func TestInsertRaw(t *testing.T) {
+	query := psql.InsertRaw("insert into users (id) values (?)", 12, 15)
+	queryStr, params, err := query.Build()
+
+	assert.NilError(t, err)
+	assert.Equal(t, "insert into users (id) values (?)", queryStr)
+	assert.DeepEqual(t, []any{12, 15}, params)
+}

dialect/psql/update.go

@@ -1,10 +1,20 @@
 package psql
 
 import (
+	"github.com/rrgmc/litsql"
 	"github.com/rrgmc/litsql/dialect/psql/tag"
+	"github.com/rrgmc/litsql/internal/ism"
 	"github.com/rrgmc/litsql/internal/ium"
 )
 
 func Update(mods ...UpdateMod) UpdateQuery {
 	return ium.Update[tag.UpdateTag](Dialect, mods...)
 }
+
+func UpdateRaw(rawQuery string, args ...any) UpdateQuery {
+	return Update(ism.RawQuery[tag.UpdateTag](rawQuery, args...))
+}
+
+func UpdateRawExpr(e litsql.Expression) UpdateQuery {
+	return Update(ism.RawQueryExpr[tag.UpdateTag](e))
+}

dialect/psql/update_test.go

@@ -20,3 +20,12 @@ func TestUpdate(t *testing.T) {
 	assert.Assert(t, queryStr != "")
 	assert.Assert(t, len(params) == 1)
 }
+
+func TestUpdateRaw(t *testing.T) {
+	query := psql.UpdateRaw("update users set name = ? where id = ?", 12, 15)
+	queryStr, params, err := query.Build()
+
+	assert.NilError(t, err)
+	assert.Equal(t, "update users set name = ? where id = ?", queryStr)
+	assert.DeepEqual(t, []any{12, 15}, params)
+}

internal/idm/rawquery.go

@@ -0,0 +1,20 @@
+package idm
+
+import (
+	"github.com/rrgmc/litsql"
+	"github.com/rrgmc/litsql/expr"
+	"github.com/rrgmc/litsql/internal/iclause"
+	"github.com/rrgmc/litsql/sq"
+)
+
+func RawQuery[T any](rawQuery string, args ...any) sq.QueryMod[T] {
+	return sq.QueryModFunc[T](func(a litsql.QueryBuilder) {
+		a.AddQueryClause(&iclause.RawQuery{Query: expr.String(rawQuery), Args: args})
+	})
+}
+
+func RawQueryExpr[T any](rawQuery litsql.Expression) sq.QueryMod[T] {
+	return sq.QueryModFunc[T](func(a litsql.QueryBuilder) {
+		a.AddQueryClause(&iclause.RawQuery{Query: rawQuery})
+	})
+}

internal/iim/rawquery.go

@@ -0,0 +1,20 @@
+package iim
+
+import (
+	"github.com/rrgmc/litsql"
+	"github.com/rrgmc/litsql/expr"
+	"github.com/rrgmc/litsql/internal/iclause"
+	"github.com/rrgmc/litsql/sq"
+)
+
+func RawQuery[T any](rawQuery string, args ...any) sq.QueryMod[T] {
+	return sq.QueryModFunc[T](func(a litsql.QueryBuilder) {
+		a.AddQueryClause(&iclause.RawQuery{Query: expr.String(rawQuery), Args: args})
+	})
+}
+
+func RawQueryExpr[T any](rawQuery litsql.Expression) sq.QueryMod[T] {
+	return sq.QueryModFunc[T](func(a litsql.QueryBuilder) {
+		a.AddQueryClause(&iclause.RawQuery{Query: rawQuery})
+	})
+}

internal/ium/rawquery.go

@@ -0,0 +1,20 @@
+package ium
+
+import (
+	"github.com/rrgmc/litsql"
+	"github.com/rrgmc/litsql/expr"
+	"github.com/rrgmc/litsql/internal/iclause"
+	"github.com/rrgmc/litsql/sq"
+)
+
+func RawQuery[T any](rawQuery string, args ...any) sq.QueryMod[T] {
+	return sq.QueryModFunc[T](func(a litsql.QueryBuilder) {
+		a.AddQueryClause(&iclause.RawQuery{Query: expr.String(rawQuery), Args: args})
+	})
+}
+
+func RawQueryExpr[T any](rawQuery litsql.Expression) sq.QueryMod[T] {
+	return sq.QueryModFunc[T](func(a litsql.QueryBuilder) {
+		a.AddQueryClause(&iclause.RawQuery{Query: rawQuery})
+	})
+}