登录
首页 >  Golang >  Go问答

gRPC 和 SQL 中的 Scan 和 Value 的用法详解

来源:stackoverflow

时间:2024-03-24 16:00:41 486浏览 收藏

gRPC 和 SQL 中的 Scan 和 Value 函数用于自定义类型的数据转换。Scan 函数允许从数据库结果集将值赋值给自定义类型变量,而 Value 函数将自定义类型转换为数据库可以存储的值。实现 Scanner 和 Valuer 接口使自定义类型能够使用 Scan 和 Value 函数。

问题内容

有人可以解释一下如何在以下示例中正确使用 scan()value() 吗?

我正在尝试使用以下示例:

  • https://github.com/jinzhu/gorm/issues/2017#issuecomment-537627961
  • https://github.com/travisjeffery/proto-go-sql/blob/master/_example/person_sql.go

我的原型:

message timestamp {
  google.protobuf.timestamp timestamp = 1;
}
message user {
  uint32 id = 1;
  timestamp createdat = 2;
}

代码(需要修复time.now()):

package v1

import (
        "database/sql/driver"
        "fmt"
        "time"

        "github.com/golang/protobuf/ptypes"
)

func (u *User) Create() {
  u.CreatedAt = time.Now() // FIXME: ERROR. How do I make use of Scan() and Value() here?

  // saving to SQL database
}

func (ts *Timestamp) Scan(value interface{}) error {
    switch t := value.(type) {
    case time.Time:
            var err error
            ts.Timestamp, err = ptypes.TimestampProto(t)
            if err != nil {
                    return err
            }
    default:
            return fmt.Errorf("Not a protobuf Timestamp")
    }
    return nil
}

func (ts Timestamp) Value() (driver.Value, error) {
        return ptypes.Timestamp(ts.Timestamp)
}

解决方案


扫描器和评估器接口实际上并不是您自己使用的东西,至少在数据库中存储自定义类型时不是这样。我将首先介绍 scan()value() 函数的使用,然后我将解决您的问题。

当您获得 sql.row 结果,并希望将结果集中的值分配(扫描)到自定义类型的变量中时。文档显示 sql.row.scan() 函数接受 0 个或多个 interface{} 类型的参数,基本上可以是任何参数。 (check docs here)。

在可以扫描值的支持类型列表中,最后一行是重要的:

任何实现扫描仪的类型(请参阅扫描仪文档)

通过函数 func (ts *timestamp) scan(value interface{}) error {timestamp 类型现在实现 scanner 接口,从而允许 sql.row 向该类型赋值。 scanner 接口的文档位于我上面链接的 scan() 文档的正下方。

当然,这可以帮助您从数据库读取值,但在存储这些类型时却无济于事。为此,您需要 valuer 接口。如果您还没有猜到, func (ts timestamp) value() (driver.value, error) 函数确实可以使您的 timestamp 类型实现此接口。 driver.valuer 接口的文档可以在 here 找到,一直在底部。

valuer 接口的要点是允许将任何类型转换为 driver.value,驱动程序可以使用该值并将其存储在数据库中(同样:docs here)。 p>

解决问题

首先,我必须假设您的协议输出已写入 v1 包。如果不是,它不会很好地为您工作。

有问题的行确实是您标记出来的行:

u.createdat = time.now()

首先,user.createdat 的类型为 timestamp,它本身就是一条包含单个时间戳的消息。要将createdat时间设置为time.now(),您需要正确初始化createdat字段:

u.CreatedAt = &Timestamp{
    Timestamp: ptypes.TimestampNow(), // this returns a PROTOBUF TYPE!
}

您已经在 scanvalue 函数中执行此操作,所以我真的不明白您为什么不在这里执行此操作...

建议

如果协议输出确实写入了 v1 包,我真的真的会删除 user.create() 函数。事实上,我会直接杀死它。您的协议缓冲区用于通信。通过 rpc 公开您的程序。这是一个 api。这些 message 类型本质上是请求和响应对象(如果您愿意的话,可以美化 dto)。您要向其中添加 create 函数,这会将它们转换为 ar 类型。它使您的 protobuf 包无法使用。 grpc 的美妙之处在于您可以生成 golang、c++、python...代码,其他人可以使用这些代码来调用您的程序。如果你让你的 grpc 包依赖于数据库,就像你所做的那样,我个人永远不会使用它。

今天带大家了解了的相关知识,希望对你有所帮助;关于Golang的技术知识我们会一点点深入介绍,欢迎大家关注golang学习网公众号,一起学习编程~

声明:本文转载于:stackoverflow 如有侵犯,请联系study_golang@163.com删除
相关阅读
更多>
最新阅读
更多>
课程推荐
更多>