diff --git a/dal/dal.go b/dal/dal.go index 9ee3a72..9217abe 100644 --- a/dal/dal.go +++ b/dal/dal.go @@ -180,7 +180,8 @@ func (d *AmoDal) Close(ctx context.Context) error { } type ClickHouseDAL struct { - conn *sql.DB + conn *sql.DB + StatisticClickRepo *statistics.StatisticClick } func NewClickHouseDAL(ctx context.Context, cred string) (*ClickHouseDAL, error) { @@ -196,8 +197,13 @@ func NewClickHouseDAL(ctx context.Context, cred string) (*ClickHouseDAL, error) return nil, fmt.Errorf("error ping database: %w", err) } + statsClickRepo := statistics.NewClickStatistic(statistics.DepsClick{ + Conn: conn, + }) + return &ClickHouseDAL{ - conn: conn, + conn: conn, + StatisticClickRepo: statsClickRepo, }, nil } diff --git a/repository/statistics/click_statistics.go b/repository/statistics/click_statistics.go new file mode 100644 index 0000000..df2774b --- /dev/null +++ b/repository/statistics/click_statistics.go @@ -0,0 +1,17 @@ +package statistics + +import "database/sql" + +type DepsClick struct { + Conn *sql.DB +} + +type StatisticClick struct { + conn *sql.DB +} + +func NewClickStatistic(deps DepsClick) *StatisticClick { + return &StatisticClick{ + conn: deps.Conn, + } +}