feat(postgres): add support for SetConnMaxLifetime (#522)

Add configuration support for database connection max lifetime:
- Add ConnMaxLifetime field to ConnectionOptions struct
- Add postgres-conn-max-lifetime CLI flag (default: 0 - disabled)
- Call SetConnMaxLifetime in OpenSQLDB when value is non-zero
- Include ConnMaxLifetime in connection logging and String() output

This allows configuring how long a connection may be reused before
being closed and replaced, helping prevent stale connections and
ensuring periodic connection refresh in the database pool.

Author: flemzord

bun/bunconnect/connect.go

@@ -20,12 +20,13 @@ type ConnectionOptions struct {
 	MaxIdleConns       int
 	MaxOpenConns       int
 	ConnMaxIdleTime    time.Duration
+	ConnMaxLifetime    time.Duration
 	Connector          func(dsn string) (driver.Connector, error) `json:",omitempty"`
 }
 
 func (opts ConnectionOptions) String() string {
-	return fmt.Sprintf("dsn=%s, max-idle-conns=%d, max-open-conns=%d, conn-max-idle-time=%s",
-		opts.DatabaseSourceName, opts.MaxIdleConns, opts.MaxOpenConns, opts.ConnMaxIdleTime)
+	return fmt.Sprintf("dsn=%s, max-idle-conns=%d, max-open-conns=%d, conn-max-idle-time=%s, conn-max-lifetime=%s",
+		opts.DatabaseSourceName, opts.MaxIdleConns, opts.MaxOpenConns, opts.ConnMaxIdleTime, opts.ConnMaxLifetime)
 }
 
 func OpenSQLDB(ctx context.Context, options ConnectionOptions, hooks ...bun.QueryHook) (*bun.DB, error) {
@@ -51,6 +52,9 @@ func OpenSQLDB(ctx context.Context, options ConnectionOptions, hooks ...bun.Quer
 	if options.ConnMaxIdleTime != 0 {
 		sqldb.SetConnMaxIdleTime(options.ConnMaxIdleTime)
 	}
+	if options.ConnMaxLifetime != 0 {
+		sqldb.SetConnMaxLifetime(options.ConnMaxLifetime)
+	}
 	if options.MaxOpenConns != 0 {
 		sqldb.SetMaxOpenConns(options.MaxOpenConns)
 	}

bun/bunconnect/flags.go

@@ -24,13 +24,15 @@ const (
 	PostgresMaxIdleConnsFlag    = "postgres-max-idle-conns"
 	PostgresMaxOpenConnsFlag    = "postgres-max-open-conns"
 	PostgresConnMaxIdleTimeFlag = "postgres-conn-max-idle-time"
+	PostgresConnMaxLifetimeFlag = "postgres-conn-max-lifetime"
 )
 
 func AddFlags(flags *pflag.FlagSet) {
 	flags.String(PostgresURIFlag, "", "Postgres URI")
 	flags.Bool(PostgresAWSEnableIAMFlag, false, "Enable AWS IAM authentication")
 	flags.Int(PostgresMaxIdleConnsFlag, 0, "Max Idle connections")
 	flags.Duration(PostgresConnMaxIdleTimeFlag, time.Minute, "Max Idle time for connections")
+	flags.Duration(PostgresConnMaxLifetimeFlag, 0, "Max lifetime for connections")
 	flags.Int(PostgresMaxOpenConnsFlag, 20, "Max opened connections")
 }
 
@@ -87,12 +89,14 @@ func ConnectionOptionsFromFlags(cmd *cobra.Command, opts ...Option) (*Connection
 	}
 	maxIdleConns, _ := cmd.Flags().GetInt(PostgresMaxIdleConnsFlag)
 	connMaxIdleConns, _ := cmd.Flags().GetDuration(PostgresConnMaxIdleTimeFlag)
+	connMaxLifetime, _ := cmd.Flags().GetDuration(PostgresConnMaxLifetimeFlag)
 	maxOpenConns, _ := cmd.Flags().GetInt(PostgresMaxOpenConnsFlag)
 
 	return &ConnectionOptions{
 		DatabaseSourceName: postgresUri,
 		MaxIdleConns:       maxIdleConns,
 		ConnMaxIdleTime:    connMaxIdleConns,
+		ConnMaxLifetime:    connMaxLifetime,
 		MaxOpenConns:       maxOpenConns,
 		Connector:          connector,
 	}, nil

bun/bunconnect/module.go

@@ -23,6 +23,7 @@ func Module(connectionOptions ConnectionOptions, debug bool) fx.Option {
 					"max-idle-conns":         connectionOptions.MaxIdleConns,
 					"max-open-conns":         connectionOptions.MaxOpenConns,
 					"max-conn-max-idle-time": connectionOptions.ConnMaxIdleTime,
+					"conn-max-lifetime":      connectionOptions.ConnMaxLifetime,
 				}).
 				Infof("opening database connection")