|
|
package main
|
|
|
|
|
|
import (
|
|
|
"dsSupport/Utils/CommonUtil"
|
|
|
"dsSupport/Utils/DbUtil"
|
|
|
"dsSupport/Utils/PgUtil"
|
|
|
"fmt"
|
|
|
)
|
|
|
|
|
|
var db = DbUtil.Engine
|
|
|
var pgDb = PgUtil.Engine
|
|
|
|
|
|
func main() {
|
|
|
//1、读取每一张需要创建的表
|
|
|
sql := "select * from t_dw_table"
|
|
|
list, _ := db.SQL(sql).Query().List()
|
|
|
|
|
|
for i := range list {
|
|
|
tableId := list[i]["table_id"].(int64)
|
|
|
tableName := list[i]["table_name"].(string)
|
|
|
createTableSql := `DROP TABLE IF EXISTS "public"."` + tableName + `";` + "\r\n"
|
|
|
pgDb.SQL(createTableSql).Execute()
|
|
|
|
|
|
createTableSql = `CREATE TABLE "public"."` + tableName + `" (` + "\r\n"
|
|
|
//2、根据表名，获取相应的创建表的信息
|
|
|
sql = `select * from t_dw_table_field where table_id=?`
|
|
|
list2, _ := db.SQL(sql, tableId).Query().List()
|
|
|
//手动增加两个字段：uuid+enable_flag
|
|
|
_map := make(map[string]interface{}, 0)
|
|
|
_map["data_type"] = "char"
|
|
|
_map["field_length"] = CommonUtil.ConvertIntToInt64(36)
|
|
|
_map["field_name"] = "uuid"
|
|
|
list2 = append(list2, _map)
|
|
|
|
|
|
_map2 := make(map[string]interface{}, 0)
|
|
|
_map2["data_type"] = "int"
|
|
|
_map2["field_length"] = CommonUtil.ConvertIntToInt64(4)
|
|
|
_map2["field_name"] = "enable_flag"
|
|
|
list2 = append(list2, _map2)
|
|
|
|
|
|
for i2 := range list2 {
|
|
|
dataType := list2[i2]["data_type"].(string)
|
|
|
fieldLength := list2[i2]["field_length"].(int64)
|
|
|
fieldName := list2[i2]["field_name"].(string)
|
|
|
var c = ""
|
|
|
if dataType == "int" {
|
|
|
c = "int" + CommonUtil.ConvertInt64ToString(fieldLength)
|
|
|
} else {
|
|
|
c = dataType + "(" + CommonUtil.ConvertInt64ToString(fieldLength) + ") " + ` COLLATE "pg_catalog"."default"`
|
|
|
}
|
|
|
c += ","
|
|
|
createTableSql += `"` + fieldName + `" ` + c + "\r\n"
|
|
|
}
|
|
|
createTableSql = createTableSql[0 : len(createTableSql)-3]
|
|
|
createTableSql += `);` + "\r\n"
|
|
|
_, err := pgDb.SQL(createTableSql).Execute()
|
|
|
fmt.Println(createTableSql)
|
|
|
if err != nil {
|
|
|
panic(err.Error())
|
|
|
}
|
|
|
//主键
|
|
|
var pks = "uuid"
|
|
|
//添加主键描述
|
|
|
createTableSql = `ALTER TABLE "public"."` + tableName + `" ADD CONSTRAINT "` + tableName + `_dw_pkey" PRIMARY KEY ("` + pks + `");` + "\r\n"
|
|
|
_, err = pgDb.SQL(createTableSql).Execute()
|
|
|
if err != nil {
|
|
|
panic(err.Error())
|
|
|
}
|
|
|
//bzlbm
|
|
|
fmt.Println("恭喜，数据仓库中相应表格创建完毕！")
|
|
|
}
|
|
|
}
|
