From 8eb1473d6472e474b8a8b37f5bf1df75a0ea083f Mon Sep 17 00:00:00 2001 From: Pavel Date: Thu, 13 Jun 2024 15:39:18 +0300 Subject: [PATCH] init stats click repo --- dal/dal.go | 10 ++++++++-- repository/statistics/click_statistics.go | 17 +++++++++++++++++ 2 files changed, 25 insertions(+), 2 deletions(-) create mode 100644 repository/statistics/click_statistics.go 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, + } +}