DataLakeSource

package
v5.4.29 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 12, 2026 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (

	//表单字段类型枚举值
	// input/number/textarea/select/radio/checkbox/date/datetime
	FIELDS_INPUT_TYPE_ENUM_INPUT    = "input"
	FIELDS_INPUT_TYPE_ENUM_NUMBER   = "number"
	FIELDS_INPUT_TYPE_ENUM_TEXTAREA = "textarea"
	FIELDS_INPUT_TYPE_ENUM_SELECT   = "select"
	FIELDS_INPUT_TYPE_ENUM_RADIO    = "radio"
	FIELDS_INPUT_TYPE_ENUM_CHECKBOX = "checkbox"
	FIELDS_INPUT_TYPE_ENUM_DATE     = "date"
	FIELDS_INPUT_TYPE_ENUM_DATETIME = "datetime"
	//字段数据类型
	// integer/bigint/float/text/bool/date/datetime
	FIELDS_DATA_TYPE_ENUM_INT      = "integer"
	FIELDS_DATA_TYPE_ENUM_INT64    = "bigint"
	FIELDS_DATA_TYPE_ENUM_FLOAT    = "float"
	FIELDS_DATA_TYPE_ENUM_TEXT     = "text"
	FIELDS_DATA_TYPE_ENUM_BOOL     = "bool"
	FIELDS_DATA_TYPE_ENUM_DATE     = "date"
	FIELDS_DATA_TYPE_ENUM_DATETIME = "datetime"
)

Functions

func ClearFields 

func ClearFields(tableID int64) (err error)

ClearFields 清理表字段

func CreateFields 

func CreateFields(args *ArgsCreateFields) (newID int64, err error)

CreateFields 创建表

func CreateTable 

func CreateTable(args *ArgsCreateTable) (newID int64, err error)

CreateTable 创建表

func DeleteFields 

func DeleteFields(id int64) (err error)

DeleteFields 删除表 必须先删除表数据和结构后才能删除，否则报错

func DeleteTable 

func DeleteTable(id int64) (err error)

DeleteTable 删除表 必须先删除表数据和结构后才能删除，否则报错

func ImportStructExcel 

func ImportStructExcel(args *ArgsImportStructExcel) (tableID int64, errCode string, err error)

ImportStructExcel 通用导入Excel文件快速建立表结构

func Init 

func Init() (err error)

func UpdateFields 

func UpdateFields(args *ArgsUpdateFields) (err error)

UpdateFields 修改表

func UpdateTable 

func UpdateTable(args *ArgsUpdateTable) (err error)

UpdateTable 修改表

Types

type ArgsCreateFields 

type ArgsCreateFields struct {
	//表ID
	TableID int64 `db:"table_id" json:"tableId" index:"true"`
	/////////////////////////////////////////////////////////////
	//表单
	/////////////////////////////////////////////////////////////
	//表单字段名称
	InputName string `db:"input_name" json:"inputName" field_search:"true"`
	//字段表单类型
	// input/textarea/select/radio/checkbox/date/datetime
	InputType string `db:"input_type" json:"inputType" field_search:"true"`
	//字段表单长度
	// 0为不限制
	InputLength int `db:"input_length" json:"inputLength"`
	//字段表单默认值
	InputDefault string `db:"input_default" json:"inputDefault"`
	//字段表单是否必填
	InputRequired bool `db:"input_required" json:"inputRequired"`
	//字段表单正则表达式
	InputPattern string `db:"input_pattern" json:"inputPattern"`
	/////////////////////////////////////////////////////////////
	//字段
	/////////////////////////////////////////////////////////////
	//字段名
	// 实体表名称，例如create_at
	// json结构会自动转化为大写驼峰命名
	FieldName string `db:"field_name" json:"fieldName" index:"true" field_search:"true"`
	//提示名称
	FieldLabel string `db:"field_label" json:"fieldLabel" field_search:"true"`
	//是否为主键
	IsPrimary bool `db:"is_primary" json:"isPrimary"`
	//字段是否为索引
	IsIndex bool `db:"is_index" json:"isIndex"`
	//是否为系统内置字段
	// id/create_at/update_at/delete_at
	IsSystem bool `db:"is_system" json:"isSystem"`
	//是否支持搜索
	IsSearch bool `db:"is_search" json:"isSearch"`
	//字段数据类型
	// int/int64/float/text/bool/date/datetime
	DataType string `db:"data_type" json:"dataType" field_search:"true"`
	//字段描述
	FieldDesc string `db:"field_desc" json:"fieldDesc" field_search:"true"`
}

ArgsCreateFields 创建表参数

type ArgsCreateTable 

type ArgsCreateTable struct {
	//表名称
	TableName string `db:"table_name" json:"tableName" field_search:"true"`
	//表描述
	TableDesc string `db:"table_desc" json:"tableDesc" field_search:"true"`
	//提示名称
	TipName string `db:"tip_name" json:"tipName" field_search:"true"`
	//数据唯一渠道名称
	// 如果是多处来源，应拆分表
	ChannelName string `db:"channel_name" json:"channelName" field_search:"true"`
	//数据唯一渠道提示名称
	ChannelTipName string `db:"channel_tip_name" json:"channelTipName" field_search:"true"`
}

ArgsCreateTable 创建表参数

type ArgsGetFieldsList 

type ArgsGetFieldsList struct {
	//分页
	Pages CoreSQL2.ArgsPages `json:"pages"`
	//表ID
	TableID int64 `db:"table_id" json:"tableId" index:"true"`
	//字段名
	FieldName string `db:"field_name" json:"fieldName" field_search:"true"`
	//字段表单类型
	InputType string `db:"input_type" json:"inputType" field_search:"true"`
	//字段数据类型
	DataType string `db:"data_type" json:"dataType" field_search:"true"`
	//是否删除
	IsRemove bool `db:"is_remove" json:"isRemove" check:"bool"`
	//搜索
	Search string `json:"search" check:"search" empty:"true"`
}

ArgsGetFieldsList 查看列表参数

type ArgsGetTableList 

type ArgsGetTableList struct {
	//分页
	Pages CoreSQL2.ArgsPages `json:"pages"`
	//是否删除
	IsRemove bool `db:"is_remove" json:"isRemove" check:"bool"`
	//搜索
	Search string `json:"search" check:"search" empty:"true"`
}

ArgsGetTableList 查看列表参数

type ArgsImportStructExcel 

type ArgsImportStructExcel struct {
	//表名称
	TableName string `db:"table_name" json:"tableName" field_search:"true"`
	//表描述
	TableDesc string `db:"table_desc" json:"tableDesc" field_search:"true"`
	//提示名称
	TipName string `db:"tip_name" json:"tipName" field_search:"true"`
	//数据唯一渠道名称
	// 如果是多处来源，应拆分表
	ChannelName string `db:"channel_name" json:"channelName" field_search:"true"`
	//数据唯一渠道提示名称
	ChannelTipName string `db:"channel_tip_name" json:"channelTipName" field_search:"true"`
	//源文件路径
	// 仅支持csv/xlsx文件
	Src string `json:"src"`
}

ArgsImportStructExcel 通用导入Excel文件快速建立表结构参数

type ArgsUpdateFields 

type ArgsUpdateFields struct {
	//ID
	ID int64 `db:"id" json:"id" check:"id"`
	/////////////////////////////////////////////////////////////
	//表单
	/////////////////////////////////////////////////////////////
	//表单字段名称
	InputName string `db:"input_name" json:"inputName" field_search:"true"`
	//字段表单类型
	// input/textarea/select/radio/checkbox/date/datetime
	InputType string `db:"input_type" json:"inputType" field_search:"true"`
	//字段表单长度
	// 0为不限制
	InputLength int `db:"input_length" json:"inputLength"`
	//字段表单默认值
	InputDefault string `db:"input_default" json:"inputDefault"`
	//字段表单是否必填
	InputRequired bool `db:"input_required" json:"inputRequired"`
	//字段表单正则表达式
	InputPattern string `db:"input_pattern" json:"inputPattern"`
	/////////////////////////////////////////////////////////////
	//字段
	/////////////////////////////////////////////////////////////
	//字段是否为索引
	IsIndex bool `db:"is_index" json:"isIndex"`
	//是否支持搜索
	IsSearch bool `db:"is_search" json:"isSearch"`
	//字段描述
	FieldDesc string `db:"field_desc" json:"fieldDesc" field_search:"true"`
}

ArgsUpdateFields 修改表参数

type ArgsUpdateTable 

type ArgsUpdateTable struct {
	//ID
	ID int64 `db:"id" json:"id" check:"id"`
	//表名称
	TableName string `db:"table_name" json:"tableName" field_search:"true"`
	//表描述
	TableDesc string `db:"table_desc" json:"tableDesc" field_search:"true"`
	//提示名称
	TipName string `db:"tip_name" json:"tipName" field_search:"true"`
	//数据唯一渠道名称
	// 如果是多处来源，应拆分表
	ChannelName string `db:"channel_name" json:"channelName" field_search:"true"`
	//数据唯一渠道提示名称
	ChannelTipName string `db:"channel_tip_name" json:"channelTipName" field_search:"true"`
}

ArgsUpdateTable 修改表参数

type FieldsFields 

type FieldsFields struct {
	//ID
	ID int64 `db:"id" json:"id" unique:"true"`
	//创建时间
	CreateAt time.Time `db:"create_at" json:"createAt" default:"now()"`
	//更新时间
	UpdateAt time.Time `db:"update_at" json:"updateAt" default:"now()"`
	//删除时间
	DeleteAt time.Time `db:"delete_at" json:"deleteAt" default:"0"`
	//表ID
	TableID int64 `db:"table_id" json:"tableId" index:"true"`
	/////////////////////////////////////////////////////////////
	//表单
	/////////////////////////////////////////////////////////////
	//表单字段名称
	InputName string `db:"input_name" json:"inputName" field_search:"true"`
	//字段表单类型
	// input/number/textarea/select/radio/checkbox/date/datetime
	InputType string `db:"input_type" json:"inputType" field_search:"true"`
	//字段表单长度
	// 0为不限制
	InputLength int `db:"input_length" json:"inputLength"`
	//字段表单默认值
	InputDefault string `db:"input_default" json:"inputDefault"`
	//字段表单是否必填
	InputRequired bool `db:"input_required" json:"inputRequired"`
	//字段表单正则表达式
	InputPattern string `db:"input_pattern" json:"inputPattern"`
	/////////////////////////////////////////////////////////////
	//字段
	/////////////////////////////////////////////////////////////
	//字段名
	// 实体表名称，例如create_at
	// json结构会自动转化为大写驼峰命名
	FieldName string `db:"field_name" json:"fieldName" index:"true" field_search:"true"`
	//提示名称
	FieldLabel string `db:"field_label" json:"fieldLabel" field_search:"true"`
	//是否为主键
	IsPrimary bool `db:"is_primary" json:"isPrimary"`
	//字段是否为索引
	IsIndex bool `db:"is_index" json:"isIndex"`
	//是否为系统内置字段
	// id/create_at/update_at/delete_at
	IsSystem bool `db:"is_system" json:"isSystem"`
	//是否支持搜索
	IsSearch bool `db:"is_search" json:"isSearch"`
	//字段数据类型
	// integer/bigint/float/text/bool/date/datetime
	DataType string `db:"data_type" json:"dataType" field_search:"true"`
	//字段描述
	FieldDesc string `db:"field_desc" json:"fieldDesc" field_search:"true"`
}

FieldsFields 表结构

func GetFieldsDetail 

func GetFieldsDetail(id int64) (data FieldsFields, err error)

GetFieldsDetail 查看表详情

func GetFieldsDetailByTableIDAndFieldName 

func GetFieldsDetailByTableIDAndFieldName(tableID int64, fieldName string) (data FieldsFields, err error)

GetFieldsDetailByTableIDAndFieldName 根据表ID和字段名称的信息

func GetFieldsList 

func GetFieldsList(args *ArgsGetFieldsList) (dataList []FieldsFields, dataCount int64, err error)

GetFieldsList 查看列表

func GetFieldsListByTableID 

func GetFieldsListByTableID(tableID int64) (dataList []FieldsFields, dataCount int64, err error)

GetFieldsListByTableID 获取表的所有列

type FieldsTable 

type FieldsTable struct {
	//ID
	ID int64 `db:"id" json:"id" unique:"true"`
	//创建时间
	CreateAt time.Time `db:"create_at" json:"createAt" default:"now()"`
	//更新时间
	UpdateAt time.Time `db:"update_at" json:"updateAt" default:"now()"`
	//删除时间
	DeleteAt time.Time `db:"delete_at" json:"deleteAt" default:"0"`
	//表名称
	TableName string `db:"table_name" json:"tableName" index:"true" field_search:"true"`
	//表描述
	TableDesc string `db:"table_desc" json:"tableDesc" field_search:"true"`
	//提示名称
	TipName string `db:"tip_name" json:"tipName" field_search:"true"`
	//数据唯一渠道名称
	// 如果是多处来源，应拆分表
	ChannelName string `db:"channel_name" json:"channelName" field_search:"true"`
	//数据唯一渠道提示名称
	ChannelTipName string `db:"channel_tip_name" json:"channelTipName" field_search:"true"`
}

FieldsTable 基础表信息 注意不要将多个来源混合到一个表中，应拆分表；可以将一个来源根据需求，进行拆分，但不推荐

func GetTableDetail 

func GetTableDetail(id int64) (data FieldsTable, err error)

GetTableDetail 查看表详情

func GetTableDetailByName 

func GetTableDetailByName(tableName string) (data FieldsTable, err error)

GetTableDetailByName 找到表名称

func GetTableList 

func GetTableList(args *ArgsGetTableList) (dataList []FieldsTable, dataCount int64, err error)

GetTableList 查看列表

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.