diff options
author | xengineering <me@xengineering.eu> | 2023-12-27 12:16:35 +0100 |
---|---|---|
committer | xengineering <me@xengineering.eu> | 2023-12-27 12:21:33 +0100 |
commit | aaf2bad8d3ab2a4f825c2d3db3f2d17de68e08b4 (patch) | |
tree | 31fb3197934eec3bbaca89871b5c095b59f96892 /vendor/github.com/mattn/go-sqlite3/sqlite3_load_extension.go | |
parent | 318f00c5d496296e45311ea81e8b80d9bd03b1d5 (diff) | |
download | ceres-aaf2bad8d3ab2a4f825c2d3db3f2d17de68e08b4.tar ceres-aaf2bad8d3ab2a4f825c2d3db3f2d17de68e08b4.tar.zst ceres-aaf2bad8d3ab2a4f825c2d3db3f2d17de68e08b4.zip |
Add github.com/mattn/go-sqlite3
This can be used to implement the `database/sql` interface from the Go
standard library for sqlite databases. This is the currently preferred
method to store user data for Ceres.
Diffstat (limited to 'vendor/github.com/mattn/go-sqlite3/sqlite3_load_extension.go')
-rw-r--r-- | vendor/github.com/mattn/go-sqlite3/sqlite3_load_extension.go | 84 |
1 files changed, 84 insertions, 0 deletions
diff --git a/vendor/github.com/mattn/go-sqlite3/sqlite3_load_extension.go b/vendor/github.com/mattn/go-sqlite3/sqlite3_load_extension.go new file mode 100644 index 0000000..9433fea --- /dev/null +++ b/vendor/github.com/mattn/go-sqlite3/sqlite3_load_extension.go @@ -0,0 +1,84 @@ +// Copyright (C) 2019 Yasuhiro Matsumoto <mattn.jp@gmail.com>. +// +// Use of this source code is governed by an MIT-style +// license that can be found in the LICENSE file. + +// +build !sqlite_omit_load_extension + +package sqlite3 + +/* +#ifndef USE_LIBSQLITE3 +#include "sqlite3-binding.h" +#else +#include <sqlite3.h> +#endif +#include <stdlib.h> +*/ +import "C" +import ( + "errors" + "unsafe" +) + +func (c *SQLiteConn) loadExtensions(extensions []string) error { + rv := C.sqlite3_enable_load_extension(c.db, 1) + if rv != C.SQLITE_OK { + return errors.New(C.GoString(C.sqlite3_errmsg(c.db))) + } + + for _, extension := range extensions { + if err := c.loadExtension(extension, nil); err != nil { + C.sqlite3_enable_load_extension(c.db, 0) + return err + } + } + + rv = C.sqlite3_enable_load_extension(c.db, 0) + if rv != C.SQLITE_OK { + return errors.New(C.GoString(C.sqlite3_errmsg(c.db))) + } + + return nil +} + +// LoadExtension load the sqlite3 extension. +func (c *SQLiteConn) LoadExtension(lib string, entry string) error { + rv := C.sqlite3_enable_load_extension(c.db, 1) + if rv != C.SQLITE_OK { + return errors.New(C.GoString(C.sqlite3_errmsg(c.db))) + } + + if err := c.loadExtension(lib, &entry); err != nil { + C.sqlite3_enable_load_extension(c.db, 0) + return err + } + + rv = C.sqlite3_enable_load_extension(c.db, 0) + if rv != C.SQLITE_OK { + return errors.New(C.GoString(C.sqlite3_errmsg(c.db))) + } + + return nil +} + +func (c *SQLiteConn) loadExtension(lib string, entry *string) error { + clib := C.CString(lib) + defer C.free(unsafe.Pointer(clib)) + + var centry *C.char + if entry != nil { + centry = C.CString(*entry) + defer C.free(unsafe.Pointer(centry)) + } + + var errMsg *C.char + defer C.sqlite3_free(unsafe.Pointer(errMsg)) + + rv := C.sqlite3_load_extension(c.db, clib, centry, &errMsg) + if rv != C.SQLITE_OK { + return errors.New(C.GoString(errMsg)) + } + + return nil +} |