Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

added auth in clickhouse #259

Merged
merged 22 commits into from
Oct 30, 2023
+92 −27
Merged

added auth in clickhouse #259

Changes from 1 commit
Commits
Show all changes
22 commits
Select commit Hold shift + click to select a range
731514b
added auth in clickhouse
Nithunikzz Oct 23, 2023
1790bd0
added comment
Nithunikzz Oct 25, 2023
5cf6c43
changes in port
Nithunikzz Oct 27, 2023
72f492e
changes in port
Nithunikzz Oct 27, 2023
ebfbbb5
changes in port
Nithunikzz Oct 27, 2023
04ffb77
changes in port
Nithunikzz Oct 27, 2023
0146a70
changes in port
Nithunikzz Oct 27, 2023
cf21e57
changes in port
Nithunikzz Oct 27, 2023
fbd91ce
changes in port
Nithunikzz Oct 27, 2023
6243c98
changes in address
Nithunikzz Oct 27, 2023
d732043
changes in address
Nithunikzz Oct 27, 2023
242aeea
changes in address
Nithunikzz Oct 27, 2023
7c45bec
changes in address
Nithunikzz Oct 27, 2023
2d01374
changes in migeration
Nithunikzz Oct 27, 2023
a5d6299
changes in migeration
Nithunikzz Oct 27, 2023
9d345bd
changes in migeration
Nithunikzz Oct 27, 2023
baf85cc
changes in migeration
Nithunikzz Oct 27, 2023
630e057
changes in migeration
Nithunikzz Oct 27, 2023
8e37196
fix
Nithunikzz Oct 30, 2023
dc0db09
fix
Nithunikzz Oct 30, 2023
db2f207
fix
Nithunikzz Oct 30, 2023
09d6441
fix
Nithunikzz Oct 30, 2023
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
45 changes: 18 additions & 27 deletions cmd/cli/config/config.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -22,35 +22,26 @@ func OpenClickHouseConn() (*sql.DB, *Config, error) {
if err != nil {
return nil, nil, err
}
//var conn clickhouse.Options
var conns clickhouse.Options
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

change the name from conns to options


conn := clickhouse.OpenDB(&clickhouse.Options{
Addr: []string{
fmt.Sprintf("%s:%d", cfg.DBAddress, cfg.DbPort)},
Debug: true,
Auth: clickhouse.Auth{
Username: cfg.ClickHouseUsername,
Password: cfg.ClickHousePassword,
},
})
// if cfg.ClickHouseUsername != "" && cfg.ClickHousePassword != "" {
// fmt.Println("Using provided username and password")
// conn = clickhouse.Options{
// Addr: []string{fmt.Sprintf("%s:%d", cfg.DBAddress, cfg.DbPort)},
// Debug: true,
// Auth: clickhouse.Auth{
// Username: cfg.ClickHouseUsername,
// Password: cfg.ClickHousePassword,
// },
// }
// } else {
// fmt.Println("Using connection without username and password")
// conn = clickhouse.Options{
// Addr: []string{fmt.Sprintf("%s:%d", conf.DBAddress, conf.DbPort)},
// }
// }
if cfg.ClickHouseUsername != "" && cfg.ClickHousePassword != "" {
fmt.Println("Using provided username and password")
conns = clickhouse.Options{
Addr: []string{fmt.Sprintf("%s:%d", cfg.DBAddress, cfg.DbPort)},
Debug: true,
Auth: clickhouse.Auth{
Username: cfg.ClickHouseUsername,
Password: cfg.ClickHousePassword,
},
}
} else {
fmt.Println("Using connection without username and password")
conns = clickhouse.Options{
Addr: []string{fmt.Sprintf("%s:%d", cfg.DBAddress, cfg.DbPort)},
}
}

// conn = clickhouse.OpenDB(&conn)
conn := clickhouse.OpenDB(&conns)
if err := conn.Ping(); err != nil {
if exception, ok := err.(*clickhouse.Exception); ok {
return nil, nil, fmt.Errorf("[%d] %s %s", exception.Code, exception.Message, exception.StackTrace)
Expand Down
Loading