qidao123.com ToB IT社区-企服评测·应用市场»论坛 › 软件与程序人生 › DevOps与敏捷开发 › 【Golang】sql.Null* 范例使用（处置惩罚空值和零值） ...

【Golang】sql.Null* 范例使用（处置惩罚空值和零值）

[复制链接]
发表于 2025-12-30 06:37:59 | 显示全部楼层 |阅读模式

马上注册，结交更多好友，享用更多功能，让你轻松玩转社区。

您需要 登录 才可以下载或查看，没有账号？立即注册

×
 sql.NullString 和 sql.NullInt64 范例（以及其他类似的 sql.Null* 范例）在处置惩罚数据库利用时非常有用，尤其是在 Go 语言的 database/sql 包中。它们的告急用途包罗：

  •         体现 NULL 值：

    • 在数据库中，NULL 体现“没有值”。sql.Null* 范例允许你在 Go 语言中直接体现和处置惩罚这种“没有值”的状态，而不是使用 Go 的零值（如空字符串 "" 或整数 0）来体现 NULL，如许可以更精确地反映数据库中的数据状态。

  •         数据库交互：

    • 当你从数据库查询数据时，某些字段大概是 NULL。使用 sql.Null* 范例可以区分一个字段是真正包罗零值还是 NULL。这对于后续的逻辑处置惩罚非常告急，由于零值和 NULL 在逻辑上大概有差异的寄义。

  •         克制错误：

    • 假如不使用 sql.Null* 范例，你大概会错误地将数据库中的 NULL 值表明为 Go 语言中的零值，这大概导致逻辑错误或步调瓦解。

  •         简化代码：

    • 使用 sql.Null* 范例可以简化代码，由于你不必要编写额外的查抄来确定一个值是否来自数据库中的 NULL。Valid 字段可以直接告诉你这个值是否有用。

  •         数据完备性：

    • 在将数据写入数据库时，sql.Null* 范例可以资助你保持数据的完备性。你可以精确地标志哪些字段是故意设置为 NULL，哪些字段是具有实际值的。

  •         机动性：

    • sql.Null* 范例提供了机动性，允许你在不改变现有代码布局的环境下，处置惩罚那些大概为 NULL 的字段。

示例场景：

假设你正在处置惩罚一个用户信息表，此中有一个字段体现用户的出生日期。在某些环境下，用户大概没有提供出生日期，因此这个字段在数据库中是 NULL。使用 sql.NullString 或 sql.NullInt64（取决于出生日期怎样存储）可以让你在 Go 步调中精确地体现这种环境，并在必要时举行恰当的处置惩罚。
  2. package main
  4. import (
  5.         "database/sql"
  6.         "fmt"
  7. )
  9. // DbBackedUser 用户结构体，由数据库支持
  10. type DbBackedUser struct {
  11.         Name sql.NullString
  12.         Age  sql.NullInt64
  13. }
  15. func main() {
  16.         // 空值
  17.         var name sql.NullString
  18.         x := DbBackedUser{Name: name, Age: sql.NullInt64{Int64: 0, Valid: false}}
  20.         // 输出结果
  21.         fmt.Println("Name:")
  22.         fmt.Println("String:", x.Name.String) // 输出: ""
  23.         fmt.Println("Valid:", x.Name.Valid)   // 输出: false
  25.         fmt.Println("Age:")
  26.         fmt.Println("Int64:", x.Age.Int64)  // 输出: 0
  27.         fmt.Println("Valid:", x.Age.Valid)   // 输出: false
  28. }
复制代码
  2. Name:
  3. String:
  4. Valid: false
  5. Age:
  6. Int64: 0
  7. Valid: false
复制代码
到场与数据库交互
1. 创建测试表

clickhouse-client
起首，我们必要在 ClickHouse 中创建一个测试表。由于你的数据布局包罗 Name 和 Age，我们可以使用以下 SQL 语句创建表： 
  2. CREATE TABLE test_table
  3. (
  4.     `Name` Nullable(String),
  5.     `Age`  Nullable(Int64)
  6. ) ENGINE = Memory;
复制代码
2. 插入数据

接下来，我们插入一些数据，包罗空值和零值：
  2. INSERT INTO test_table VALUES ('Kimi', 30), ('', 0), (NULL, NULL);
复制代码
这里，我们插入了三行数据：

  • 第一行：Name 是 "Kimi"，Age 是 30。
  • 第二行：Name 是空字符串，Age 是 0。
  • 第三行：Name 和 Age 都是 NULL。
3. 查询数据

查询表中的全部数据：
  2. SELECT * FROM test_table;
复制代码
  2. package main
  4. import (
  5.         "database/sql"
  6.         "fmt"
  7.         "log"
  9.         _ "github.com/ClickHouse/clickhouse-go"
  10. )
  12. // DbBackedUser 用户结构体，由数据库支持
  13. type DbBackedUser struct {
  14.         Name sql.NullString
  15.         Age  sql.NullInt64
  16. }
  18. func main() {
  19.         // 连接到 ClickHouse 数据库
  20.         connStr := "tcp://localhost:9000?username=default&password=&database=default"
  21.         db, err := sql.Open("clickhouse", connStr)
  22.         if err != nil {
  23.                 log.Fatal(err)
  24.         }
  25.         defer db.Close()
  27.         // 查询并打印现有的数据
  28.         fmt.Println("Query results before insertion:")
  29.         queryData(db)
  30.         fmt.Println("查询并打印现有的数据")
  32.         // 开始事务
  33.         tx, err := db.Begin()
  34.         if err != nil {
  35.                 log.Fatal(err)
  36.         }
  38.         // 空值
  39.         var name sql.NullString
  40.         x := DbBackedUser{Name: name, Age: sql.NullInt64{Int64: 1, Valid: false}}
  42.         // 插入数据
  43.         _, err = tx.Exec("INSERT INTO test_table2 (Name, Age) VALUES (?, ?)", x.Name, x.Age)
  44.         if err != nil {
  45.                 tx.Rollback() // 如果出现错误，回滚事务
  46.                 log.Fatal(err)
  47.         }
  49.         // 提交事务
  50.         err = tx.Commit()
  51.         if err != nil {
  52.                 log.Fatal(err)
  53.         }
  55.         // 查询并打印插入后的数据
  56.         fmt.Println("Query results after insertion:")
  57.         queryData(db)
  58.         fmt.Println("查询并打印现有的数据")
  60. }
  62. func queryData(db *sql.DB) {
  63.         rows, err := db.Query("SELECT Name, Age FROM test_table2")
  64.         if err != nil {
  65.                 log.Fatal(err)
  66.         }
  67.         defer rows.Close()
  69.         var nameValue sql.NullString
  70.         var ageValue sql.NullInt64
  71.         for rows.Next() {
  72.                 if err := rows.Scan(&nameValue, &ageValue); err != nil {
  73.                         log.Fatal(err)
  74.                 }
  75.                 fmt.Printf("name: %v, Age: %v\n", nameValue.String, ageValue.Int64)
  76.         }
  77. }
复制代码
效果

这里

给数据库传了0值
改成true后

传值乐成

NameValid改成false

传null
  2. package main
  4. import (
  5.         "database/sql"
  6.         "fmt"
  7.         "reflect"
  9.         "github.com/go-playground/validator/v10"
  10. )
  12. // DbBackedUser 用户结构体，由数据库支持
  13. type DbBackedUser struct {
  14.         Name sql.NullString `validate:"required"` // 可以为NULL的字符串，验证规则为必填
  15.         Age  sql.NullInt64  `validate:"required"` // 可以为NULL的整数，验证规则为必填
  16. }
  18. // 使用单一实例的验证器，它缓存结构体信息
  19. var validate *validator.Validate
  21. func main() {
  22.         // 创建一个新的验证器实例
  23.         validate = validator.New()
  25.         // 注册所有sql.Null*类型，使用自定义的ValidateValuer函数
  26.         validate.RegisterCustomTypeFunc(ValidateValuer, sql.NullString{}, sql.NullInt64{})
  28.         // 构建对象进行验证
  29.         // Name字段为空字符串但Valid为true，表示非NULL；Age字段为0且Valid为false，表示NULL
  30.         x := DbBackedUser{Name: sql.NullString{String: "zahngsan", Valid: true}, Age: sql.NullInt64{Int64: 18, Valid: false}}
  32.         // 对x进行结构体验证
  33.         err := validate.Struct(x)
  35.         // 如果验证失败，打印错误信息
  36.         if err != nil {
  37.                 fmt.Printf("Err(s):\n%+v\n", err)
  38.         }
  39. }
  41. // ValidateValuer实现了validator.CustomTypeFunc接口
  42. func ValidateValuer(field reflect.Value) interface{} {
  43.         // 检查field是否为nil
  44.         if !field.IsValid() {
  45.                 return nil
  46.         }
  48.         // 检查field是否实现了sql.Null*类型
  49.         if nullType, ok := field.Interface().(sql.NullString); ok {
  50.                 // 如果Valid为true，返回字符串和非NULL的指示
  51.                 if nullType.Valid {
  52.                         fmt.Println("NullString Valid为true:",nullType.String)
  53.                         return []interface{}{nullType.String, true}
  54.                 }
  55.                 // 如果Valid为false，返回空字符串和NULL的指示
  56.                 fmt.Println("NullString Valid为false")
  57.                 return []interface{}{"", false}
  58.         }
  60.         // 检查field是否实现了sql.NullInt64类型
  61.         if nullInt64, ok := field.Interface().(sql.NullInt64); ok {
  62.                 if nullInt64.Valid {
  63.                         fmt.Println("NullInt64 Valid为true:",nullInt64.Int64)
  64.                         return []interface{}{nullInt64.Int64,true}
  65.                 }
  66.                 fmt.Println("NullInt64 Valid为false")
  67.                 return []interface{}{"", false}
  68.         }
  70.         // 对其他sql.Null*类型进行类似的处理...
  71.         // ...
  73.         // 如果不是sql.Null*类型，返回nil
  74.         return nil
  75. }
复制代码
效果
回复

使用道具 举报

返回列表

悠扬随风
+ 我要发帖

登录后关闭弹窗

登录参与点评抽奖  加入IT实名职场社区
去登录
快速回复 返回顶部 返回列表