Commit cc80b3d6 authored by Andrei Mihu's avatar Andrei Mihu
Browse files

Improve handling of database connections going through proxies.

parent 7a35302f

CHANGELOG.md

+1 −0
Original line number Diff line number Diff line
@@ -7,6 +7,7 @@ The format is based on [keep a changelog](http://keepachangelog.com) and this pr 
### Changed

- More consistent signature and handling between JavaScript runtime Base64 encode functions.

- Improve group list cursor handling for messages with close timestamps.

- Improve handling of database connections going through proxies.



### Fixed

- Graceful handling of storage list errors in JavaScript runtime.

migrate/migrate.go

+8 −0
Original line number Diff line number Diff line
@@ -128,8 +128,16 @@ func Parse(args []string, tmpLogger *zap.Logger) { 
		logger.Fatal("Bad connection URL", zap.Error(err))

	}

	query := parsedURL.Query()

	var queryUpdated bool

	if len(query.Get("sslmode")) == 0 {

		query.Set("sslmode", "prefer")

		queryUpdated = true

	}

	if len(query.Get("statement_cache_mode")) == 0 {

		query.Set("statement_cache_mode", "describe")

		queryUpdated = true

	}

	if queryUpdated {

		parsedURL.RawQuery = query.Encode()

	}

server/db.go

+8 −0
Original line number Diff line number Diff line
@@ -42,8 +42,16 @@ func DbConnect(ctx context.Context, logger *zap.Logger, config Config) (*sql.DB, 
		logger.Fatal("Bad database connection URL", zap.Error(err))

	}

	query := parsedURL.Query()

	var queryUpdated bool

	if len(query.Get("sslmode")) == 0 {

		query.Set("sslmode", "prefer")

		queryUpdated = true

	}

	if len(query.Get("statement_cache_mode")) == 0 {

		query.Set("statement_cache_mode", "describe")

		queryUpdated = true

	}

	if queryUpdated {

		parsedURL.RawQuery = query.Encode()

	}