日本免费高清视频-国产福利视频导航-黄色在线播放国产-天天操天天操天天操天天操|www.shdianci.com

學(xué)無先后,達(dá)者為師

網(wǎng)站首頁 編程語言 正文

Go實(shí)現(xiàn)簡單的數(shù)據(jù)庫表轉(zhuǎn)結(jié)構(gòu)體詳解_Golang

作者:六號積極分子 ? 更新時(shí)間: 2023-02-26 編程語言

前言

碼上源碼

package main
import (
	"database/sql"
	"fmt"
	_ "github.com/go-sql-driver/mysql"
	"strings"
)
/**
  自動(dòng)將表生成 model結(jié)構(gòu),
 通過創(chuàng)建數(shù)據(jù)庫連接,讀取數(shù)據(jù)庫的所有表并對所有的表元數(shù)據(jù)封裝轉(zhuǎn)化實(shí)體結(jié)構(gòu)體
*/
type SchemaMeta struct {
	Field   string
	Type    string
	Null    string
	Key     string
	Default interface{}
	Extra   string
}
func main() {
	dbString := "{YOUR_MYSQL_CONNECTION}"
	db, _ := sql.Open("mysql", dbString)
	tables := getTables(db)
	for _, table := range tables {
		metas := getTableInfo(table, db)
		result := changeMetas(table, metas)
		fmt.Println(result)
	}
}
func getTables(db *sql.DB) []string {
	var tables []string
	res, _ := db.Query("SHOW TABLES")
	for res.Next() {
		var table string
		res.Scan(&table)
		tables = append(tables, table)
	}
	return tables
}
func getTableInfo(tableName string, db *sql.DB) (metas []SchemaMeta) {
	list, _ := db.Query(fmt.Sprintf("show columns from %s", tableName))
	for list.Next() {
		var data SchemaMeta
		err := list.Scan(&data.Field, &data.Type, &data.Null, &data.Key, &data.Default, &data.Extra)
		if err != nil {
			fmt.Println(err.Error())
		}
		metas = append(metas, data)
	}
	return metas
}
func changeMetas(tableName string, metas []SchemaMeta) string {
	var modelStr string
	for _, val := range metas {
		dataType := "interface{}"
		if val.Type[:3] == "int" {
			dataType = "int"
		} else if val.Type[:7] == "varchar" {
			dataType = "string"
		} else if val.Type[:7] == "tinyint" {
			dataType = "bool"
		} else if val.Type == "datetime" {
			dataType = "time.Time"
		}
		field := val.Field
		field = strings.ToUpper(field[:1]) + field[1:]
		modelStr += fmt.Sprintf("%s %s\n", field, dataType)
	}
	tableName = strings.ToUpper(tableName[:1]) + tableName[1:]
	return fmt.Sprintf("type %s struct {\n %s }", tableName, modelStr)
}

設(shè)計(jì)好了數(shù)據(jù)庫表之后最煩的就是又要在代碼中建一層實(shí)體層然后一個(gè)個(gè)創(chuàng)建對應(yīng)表的結(jié)構(gòu)體。關(guān)鍵那么多項(xiàng)目每次都是需要?jiǎng)?chuàng)建一份,所以就使用 go 實(shí)現(xiàn)一個(gè)簡單的將數(shù)據(jù)庫的表轉(zhuǎn)化為結(jié)構(gòu)體。

基本的設(shè)計(jì)思路也是很簡單:

  • 連接數(shù)據(jù)庫
  • 獲取數(shù)據(jù)庫中所有的表
  • 獲取表的所有的元數(shù)據(jù)
  • 將元數(shù)據(jù)轉(zhuǎn)換為字符串,該字符串就是一個(gè) struct的內(nèi)容并輸出結(jié)果

設(shè)計(jì)過程

經(jīng)常使用 MySQL 的時(shí)候,可以通過 SQL 語句查詢相關(guān)的信息,比如查看數(shù)據(jù)庫的狀態(tài)、數(shù)據(jù)庫的數(shù)據(jù)表、數(shù)據(jù)庫服務(wù)的狀態(tài)等等語句。

show databases 查看所有的數(shù)據(jù)庫
show tables [from dbName] 查看數(shù)據(jù)庫的所有表數(shù)據(jù)
show columns from tableName [from dbName] 查看數(shù)據(jù)庫表的所有元信息
show status 查看數(shù)據(jù)服務(wù)的狀態(tài)

所以就可以使用以上的 SQL 語句進(jìn)行相操作,比如獲取所有的表,獲取相關(guān)表的元數(shù)據(jù)

func getTableInfo(tableName string, db *sql.DB) (metas []SchemaMeta) {
    list, _ := db.Query(fmt.Sprintf("show columns from %s", tableName))
    for list.Next() {
        var data SchemaMeta
        err := list.Scan(&data.Field, &data.Type, &data.Null, &data.Key, &data.Default, &data.Extra)
        if err != nil {
            fmt.Println(err.Error())
        }
        metas = append(metas, data)
    }
    return metas
}

表的元數(shù)據(jù)獲取完之后就可以進(jìn)行封裝成一個(gè)字符串。最主要的功能有兩個(gè):

  • db 數(shù)據(jù)類型轉(zhuǎn) go 數(shù)據(jù)類型
  • 首字母大小寫,

數(shù)據(jù)類型的轉(zhuǎn)換簡單處理的話可以使用枚舉的方式將 db 數(shù)據(jù)類型和 go 的數(shù)據(jù)類型建立一個(gè)map 進(jìn)行一一對應(yīng),當(dāng)然也可以使用模糊匹配的方式。我這里直接使用截取字符串值去匹配。

因要設(shè)置為對象類型,必須設(shè)置為公有的,所以結(jié)構(gòu)體名稱和字段名稱都必須是大寫。直接使用截取第一位然后進(jìn)行大寫轉(zhuǎn)換再重新拼接出去。比如 field = strings.ToUpper(field[:1]) + field[1:]。這部分的數(shù)據(jù)大小寫還需要根據(jù)自己的需求進(jìn)行調(diào)整,比如有寫字段是這樣:“user_code”那么轉(zhuǎn)換成字段應(yīng)該是“UserCode”。

轉(zhuǎn)換完之后就可以輸出,一個(gè)簡單的工具就完成了。

迭代升級

  • 支持多種數(shù)據(jù)庫:現(xiàn)目前使用的是 MySQL 數(shù)據(jù)庫進(jìn)行開發(fā),而市面上其實(shí)有很多種數(shù)據(jù),所以這部分可以繼續(xù)擴(kuò)展支持多種數(shù)據(jù)庫。
  • 數(shù)據(jù)類型轉(zhuǎn)換:現(xiàn)只支持自己所使用的相關(guān)數(shù)據(jù)類型
  • 如果有前端搭配使用可以涉及按需生成

原文鏈接:https://juejin.cn/post/7185879436028280888

欄目分類
最近更新