当前位置：首页 > news >正文

01-第1章-概述与快速开始

news 2026/5/23 14:29:45

第 1 章：概述与快速开始

1.1 sfsDb 简介

sfsDb 是一款专为工业物联网（IIoT）和边缘计算场景设计的纯 Go 语言嵌入式数据库。它基于 LevelDB 构建，提供了无锁事务系统、高效索引管理、时序数据处理和加密存储等功能。

核心特性

纯 Go 实现：无需 CGO，跨平台编译简单
创新性地将 NoSQL 的高并发写入能力与 SQL 的复杂查询能力融合在一个系统中
无锁事务：基于 OCC（乐观并发控制）的高性能事务系统
多种索引：支持主键、普通索引、复合索引和全文索引
时序数据优化：内置时间窗口计算和数据聚合功能
加密存储：支持 AES-256-GCM 加密
嵌入式设计：无需独立服务器进程

1.2 环境搭建

安装 sfsDb

go get github.com/liaoran123/sfsDb

依赖要求

Go 1.25+
github.com/syndtr/goleveldb v1.0.0

1.3 完整的可运行示例

让我们通过一个完整的示例来演示 sfsDb 的基本使用：

packagemainimport("fmt""os""github.com/liaoran123/sfsDb/engine""github.com/liaoran123/sfsDb/storage")funcmain(){fmt.Println("=== sfsDb 数据库实战 - 第 1 章：Hello World 示例 ===")fmt.Println()dbPath:="./bible_examples_chapter01_db"cleanup(dbPath)fmt.Println("1. 初始化数据库")_,err:=storage.GetDBManager().OpenDB(dbPath)iferr!=nil{fmt.Printf("数据库打开失败: %v\n",err)return}deferstorage.GetDBManager().CloseDB()fmt.Println(" ✓ 数据库打开成功")fmt.Println()fmt.Println("2. 创建用户表")userTable,err:=engine.TableNew("users")iferr!=nil{fmt.Printf("创建表失败: %v\n",err)return}fmt.Println(" ✓ 表创建成功")fmt.Println()fmt.Println("3. 设置字段")userFields:=map[string]any{"id":0,// 用户ID"name":"",// 用户名"age":0,// 年龄"email":"",// 邮箱"address":"",// 地址}err=userTable.SetFields(userFields)iferr!=nil{fmt.Printf("设置字段失败: %v\n",err)return}fmt.Println(" ✓ 字段设置成功")fmt.Println()fmt.Println("4. 创建主键索引")primaryKey,err:=engine.DefaultPrimaryKeyNew("pk_id")iferr!=nil{fmt.Printf("创建主键索引失败: %v\n",err)return}primaryKey.AddFields("id")err=userTable.CreateIndex(primaryKey)iferr!=nil{fmt.Printf("创建索引失败: %v\n",err)return}fmt.Println(" ✓ 主键索引创建成功")fmt.Println()fmt.Println("5. 插入测试数据")testUser:=map[string]any{"id":1,"name":"张三","age":28,"email":"zhangsan@example.com","address":"北京市朝阳区",}_,err=userTable.Insert(&amp;testUser)iferr!=nil{fmt.Printf("插入数据失败: %v\n",err)return}fmt.Println(" ✓ 测试数据插入成功")fmt.Println()fmt.Println("6. 查询测试数据")searchFields:=map[string]any{"id":1}dataIter,_:=userTable.Search(&amp;searchFields)deferdataIter.Release()records:=dataIter.GetRecords(true)deferrecords.Release()iflen(records)&gt;0{fmt.Println(" ✓ 查询成功！")fmt.Printf(" 用户信息: %+v\n",records[0])}else{fmt.Println(" ✗ 查询失败，未找到记录")}fmt.Println()fmt.Println("=== 恭喜！sfsDb 入门成功！ ===")fmt.Println()fmt.Println("接下来，请继续阅读第 2 章，了解 sfsDb 的核心概念与架构。")}funccleanup(pathstring){os.RemoveAll(path)}