Sqinn-Go: 纯Go实现的SQLite操作库

Sqinn-Go是一个纯Go实现的SQLite数据库操作库，它不需要依赖CGO，而是通过Sqinn子进程与SQLite交互。这使得它成为跨平台部署的理想选择，特别是在需要静态链接或避免CGO依赖的场景中。

安装Sqinn-Go

首先安装Sqinn-Go库：

go get github.com/cvilsmeier/sqinn-go/sqinn

基本使用方法

1. 初始化数据库连接

package main

import (
	"fmt"
	"log"
	"github.com/cvilsmeier/sqinn-go/sqinn"
)

func main() {
	// 创建Sqinn实例
	sq, err := sqinn.Launch(sqinn.Options{
		SqinnPath: "sqinn", // sqinn可执行文件路径
	})
	if err != nil {
		log.Fatalf("启动sqinn失败: %v", err)
	}
	defer sq.Terminate()

	// 打开数据库连接
	err = sq.Open("test.db")
	if err != nil {
		log.Fatalf("打开数据库失败: %v", err)
	}
	defer sq.Close()

	// 执行SQL语句
	_, err = sq.ExecOne("CREATE TABLE IF NOT EXISTS users (id INTEGER PRIMARY KEY, name TEXT, age INTEGER)")
	if err != nil {
		log.Fatalf("创建表失败: %v", err)
	}

	fmt.Println("数据库初始化完成")
}

2. 插入数据

// 插入单条数据
func insertUser(sq *sqinn.Sqinn, name string, age int) error {
	_, err := sq.ExecOne("INSERT INTO users (name, age) VALUES (?, ?)", name, age)
	return err
}

// 批量插入数据
func batchInsertUsers(sq *sqinn.Sqinn, users []struct{Name string; Age int}) error {
	// 开始事务
	err := sq.ExecOne("BEGIN")
	if err != nil {
		return err
	}
	
	// 确保事务要么提交要么回滚
	defer func() {
		if err != nil {
			sq.ExecOne("ROLLBACK")
		}
	}()
	
	// 批量插入
	for _, user := range users {
		_, err = sq.ExecOne("INSERT INTO users (name, age) VALUES (?, ?)", user.Name, user.Age)
		if err != nil {
			return err
		}
	}
	
	// 提交事务
	return sq.ExecOne("COMMIT")
}

3. 查询数据

// 查询所有用户
func queryAllUsers(sq *sqinn.Sqinn) ([]struct{ID int; Name string; Age int}, error) {
	// 执行查询
	rows, err := sq.Query("SELECT id, name, age FROM users ORDER BY id")
	if err != nil {
		return nil, err
	}
	defer rows.Close()

	// 处理结果集
	var users []struct{ID int; Name string; Age int}
	for rows.Next() {
		var id int
		var name string
		var age int
		err := rows.Scan(&id, &name, &age)
		if err != nil {
			return nil, err
		}
		users = append(users, struct{ID int; Name string; Age int}{id, name, age})
	}

	return users, nil
}

// 查询单个用户
func queryUserById(sq *sqinn.Sqinn, id int) (struct{Name string; Age int}, error) {
	row, err := sq.QueryRow("SELECT name, age FROM users WHERE id = ?", id)
	if err != nil {
		return struct{Name string; Age int}{}, err
	}
	defer row.Close()

	var name string
	var age int
	err = row.Scan(&name, &age)
	if err != nil {
		return struct{Name string; Age int}{}, err
	}

	return struct{Name string; Age int}{name, age}, nil
}

4. 更新和删除数据

// 更新用户信息
func updateUser(sq *sqinn.Sqinn, id int, name string, age int) error {
	_, err := sq.ExecOne("UPDATE users SET name = ?, age = ? WHERE id = ?", name, age, id)
	return err
}

// 删除用户
func deleteUser(sq *sqinn.Sqinn, id int) error {
	_, err := sq.ExecOne("DELETE FROM users WHERE id = ?", id)
	return err
}

高级特性

1. 预处理语句

// 使用预处理语句提高性能
func batchInsertWithPreparedStatement(sq *sqinn.Sqinn, users []struct{Name string; Age int}) error {
	// 准备语句
	stmt, err := sq.Prepare("INSERT INTO users (name, age) VALUES (?, ?)")
	if err != nil {
		return err
	}
	defer sq.Finalize(stmt)

	// 开始事务
	err = sq.ExecOne("BEGIN")
	if err != nil {
		return err
	}
	
	defer func() {
		if err != nil {
			sq.ExecOne("ROLLBACK")
		}
	}()
	
	// 批量执行
	for _, user := range users {
		_, err = sq.Exec(stmt, user.Name, user.Age)
		if err != nil {
			return err
		}
	}
	
	// 提交事务
	return sq.ExecOne("COMMIT")
}

2. 处理BLOB数据

// 插入BLOB数据
func insertBlob(sq *sqinn.Sqinn, id int, data []byte) error {
	_, err := sq.ExecOne("INSERT INTO blobs (id, data) VALUES (?, ?)", id, data)
	return err
}

// 查询BLOB数据
func queryBlob(sq *sqinn.Sqinn, id int) ([]byte, error) {
	row, err := sq.QueryRow("SELECT data FROM blobs WHERE id = ?", id)
	if err != nil {
		return nil, err
	}
	defer row.Close()

	var data []byte
	err = row.Scan(&data)
	return data, err
}

注意事项

1. 性能考虑：由于Sqinn-Go通过子进程通信，性能可能不如直接使用CGO的SQLite驱动。但对于大多数应用场景已经足够。

2. 错误处理：务必检查所有数据库操作的错误返回。

3. 资源释放：确保及时关闭数据库连接、语句和结果集。

4. 并发安全：Sqinn-Go实例不是并发安全的，需要在多个goroutine中使用时添加同步机制。

5. SQLite特性：Sqinn-Go支持大多数SQLite特性，但某些高级功能可能不可用。

Sqinn-Go为Go开发者提供了一个不依赖CGO的SQLite解决方案，特别适合需要跨平台部署或静态链接的场景。虽然性能上可能略有牺牲，但换来了更好的可移植性和部署便利性。