package etl
|
|
|
|
import (
|
|
model "LAPP_ETL/models/etl"
|
|
"LAPP_ETL/services/etl/implments"
|
|
)
|
|
|
|
/******************************************************************************
|
|
*
|
|
* @Interface Name : LoadService
|
|
*-----------------------------------------------------------------------------
|
|
*
|
|
* @Description : LoadService的服务接口
|
|
*
|
|
* @Author : zhangxin
|
|
*
|
|
* @Date : 2021-06-02
|
|
*
|
|
******************************************************************************/
|
|
type LoadService interface {
|
|
/******************************************************************************
|
|
*
|
|
* @Function Name : Load
|
|
*-----------------------------------------------------------------------------
|
|
*
|
|
* @Description : 加载数据到目标数据库
|
|
*
|
|
* @Function Parameters : taskHead
|
|
*
|
|
* @Author : zhangxin
|
|
*
|
|
* @Date : 2021-06-02
|
|
*
|
|
******************************************************************************/
|
|
Load(*model.TaskHead)
|
|
}
|
|
|
|
/******************************************************************************
|
|
*
|
|
* @Function Name : NewLoadService
|
|
*-----------------------------------------------------------------------------
|
|
*
|
|
* @Description : 创建一个NewLoadService
|
|
*
|
|
* @Return Value :NewLoadService实例
|
|
*
|
|
* @Author : zhangxin
|
|
*
|
|
* @Date : 2021-06-02
|
|
*
|
|
******************************************************************************/
|
|
func NewLoadService() LoadService {
|
|
return implments.NewLoadServiceImplement()
|
|
}
|