diff options
Diffstat (limited to 'sqlite3_opt_preupdate_hook.go')
-rw-r--r-- | sqlite3_opt_preupdate_hook.go | 113 |
1 files changed, 0 insertions, 113 deletions
diff --git a/sqlite3_opt_preupdate_hook.go b/sqlite3_opt_preupdate_hook.go deleted file mode 100644 index 8cce278..0000000 --- a/sqlite3_opt_preupdate_hook.go +++ /dev/null @@ -1,113 +0,0 @@ -// Copyright (C) 2019 G.J.R. Timmer <gjr.timmer@gmail.com>. -// Copyright (C) 2018 segment.com <friends@segment.com> -// -// Use of this source code is governed by an MIT-style -// license that can be found in the LICENSE file. - -//go:build sqlite_preupdate_hook -// +build sqlite_preupdate_hook - -package sqlite3 - -/* -#cgo CFLAGS: -DSQLITE_ENABLE_PREUPDATE_HOOK -#cgo LDFLAGS: -lm - -#ifndef USE_LIBSQLITE3 -#include "sqlite3-binding.h" -#else -#include <sqlite3.h> -#endif -#include <stdlib.h> -#include <string.h> - -void preUpdateHookTrampoline(void*, sqlite3 *, int, char *, char *, sqlite3_int64, sqlite3_int64); -*/ -import "C" -import ( - "errors" - "unsafe" -) - -// RegisterPreUpdateHook sets the pre-update hook for a connection. -// -// The callback is passed a SQLitePreUpdateData struct with the data for -// the update, as well as methods for fetching copies of impacted data. -// -// If there is an existing preupdate hook for this connection, it will be -// removed. If callback is nil the existing hook (if any) will be removed -// without creating a new one. -func (c *SQLiteConn) RegisterPreUpdateHook(callback func(SQLitePreUpdateData)) { - if callback == nil { - C.sqlite3_preupdate_hook(c.db, nil, nil) - } else { - C.sqlite3_preupdate_hook(c.db, (*[0]byte)(unsafe.Pointer(C.preUpdateHookTrampoline)), unsafe.Pointer(newHandle(c, callback))) - } -} - -// Depth returns the source path of the write, see sqlite3_preupdate_depth() -func (d *SQLitePreUpdateData) Depth() int { - return int(C.sqlite3_preupdate_depth(d.Conn.db)) -} - -// Count returns the number of columns in the row -func (d *SQLitePreUpdateData) Count() int { - return int(C.sqlite3_preupdate_count(d.Conn.db)) -} - -func (d *SQLitePreUpdateData) row(dest []any, new bool) error { - for i := 0; i < d.Count() && i < len(dest); i++ { - var val *C.sqlite3_value - var src any - - // Initially I tried making this just a function pointer argument, but - // it's absurdly complicated to pass C function pointers. - if new { - C.sqlite3_preupdate_new(d.Conn.db, C.int(i), &val) - } else { - C.sqlite3_preupdate_old(d.Conn.db, C.int(i), &val) - } - - switch C.sqlite3_value_type(val) { - case C.SQLITE_INTEGER: - src = int64(C.sqlite3_value_int64(val)) - case C.SQLITE_FLOAT: - src = float64(C.sqlite3_value_double(val)) - case C.SQLITE_BLOB: - len := C.sqlite3_value_bytes(val) - blobptr := C.sqlite3_value_blob(val) - src = C.GoBytes(blobptr, len) - case C.SQLITE_TEXT: - len := C.sqlite3_value_bytes(val) - cstrptr := unsafe.Pointer(C.sqlite3_value_text(val)) - src = C.GoBytes(cstrptr, len) - case C.SQLITE_NULL: - src = nil - } - - err := convertAssign(&dest[i], src) - if err != nil { - return err - } - } - - return nil -} - -// Old populates dest with the row data to be replaced. This works similar to -// database/sql's Rows.Scan() -func (d *SQLitePreUpdateData) Old(dest ...any) error { - if d.Op == SQLITE_INSERT { - return errors.New("There is no old row for INSERT operations") - } - return d.row(dest, false) -} - -// New populates dest with the replacement row data. This works similar to -// database/sql's Rows.Scan() -func (d *SQLitePreUpdateData) New(dest ...any) error { - if d.Op == SQLITE_DELETE { - return errors.New("There is no new row for DELETE operations") - } - return d.row(dest, true) -} |