golang sql根据struct字段来生成记录

/*
	Author        : tuxpy
	Email         : q8886888@qq.com.com
	Create time   : 2017-11-04 23:13:08
	Filename      : main.go
	Description   :
*/

package main

import (
	"database/sql"
	"errors"
	"fmt"
	"reflect"
	"time"
	"utils"

	_ "github.com/mattn/go-sqlite3"
)

func ToStruct(rows *sql.Rows,to interface{}) error {
	v := reflect.ValueOf(to)
	if v.Elem().Type().Kind() != reflect.Struct {
		return errors.New("Expect a struct")
	}

	scan_dest := []interface{}{}
	column_names,_ := rows.Columns()

	addr_by_column_name := map[string]interface{}{}

	for i := 0; i < v.Elem().NumField(); i++ {
		one_value := v.Elem().Field(i)
		column_name := v.Elem().Type().Field(i).Tag.Get("sql")
		if column_name == "" {
			column_name = one_value.Type().Name()
		}
		addr_by_column_name[column_name] = one_value.Addr().Interface()
	}

	for _,column_name := range column_names {
		scan_dest = append(scan_dest,addr_by_column_name[column_name])
	}

	return rows.Scan(scan_dest...)

}

func main() {
	db,err := sql.Open("sqlite3","/tmp/firstlink.db")
	utils.CheckErrorPanic(err)
	fmt.Println(db)
	db.Exec(`CREATE TABLE userinfo (
		work_id INTEGER PRIMARY KEY AUTOINCREMENT,name VARCHAR(64) NULL,departname VARCHAR(64) NULL,created DATE NULL
	)`)

	tx,err := db.Begin()

	defer func() {
		tx.Commit()
	}()
	utils.CheckErrorPanic(err)

	//	stmt,err := tx.Prepare("INSERT INTO userinfo(name,departname,created) values(?,?,?);")
	//	utils.CheckErrorPanic(err)
	//
	//	_,err = stmt.Exec("我","爬虫","2015-12-15")
	//	_,err = stmt.Exec("你","客服","2015-12-16")
	//	utils.CheckErrorPanic(err)

	rows,err := tx.Query("SELECT work_id,name,created FROM userinfo")
	utils.CheckErrorPanic(err)

	type Record struct {
		Name    string    `sql:"name"`
		WorkID  int       `sql:"work_id"`
		Created time.Time `sql:"created"`
	}

	for rows.Next() {
		record := Record{}

		utils.CheckErrorPanic(ToStruct(rows,&record))
		fmt.Println(record.WorkID,record.Name,record.Created)
	}
}

输出:

&{0xc42000c3e0 /tmp/firstlink.db 0 {0 0} [] map[] 0 0 0xc4200ee060 false map[] map[] 0 0 0 <nil>}
1 我 2015-12-15 00:00:00 +0000 UTC
2 你 2015-12-16 00:00:00 +0000 UTC

相关文章

程序目录结构 简单实现,用户登录后返回一个jwt的token,下次请求带上token请求用户信息接口并返回信息...
本篇博客的主要内容是用go写一个简单的Proof-of-Work共识机制,不涉及到网络通信环节,只是一个本地的简...
简介 默克尔树(MerkleTree)是一种典型的二叉树结构,其主要特点为: 最下面的叶节点包含存储数据或其...
接下来学习并发编程, 并发编程是go语言最有特色的地方, go对并发编程是原生支持. goroutine是go中最近本...
先普及一下, 什么是广度优先搜索 广度优先搜索类似于树的层次遍历。从图中的某一顶点出发,遍历每一个顶...
第一天: 接口的定义和实现 第二天: 一. go语言是面向接口编程. 在学习继承的时候说过, go语言只有封装,...