diff --git a/weed/server/postgres/protocol.go b/weed/server/postgres/protocol.go index cf5344464..a67027384 100644 --- a/weed/server/postgres/protocol.go +++ b/weed/server/postgres/protocol.go @@ -10,6 +10,7 @@ import ( "github.com/seaweedfs/seaweedfs/weed/glog" "github.com/seaweedfs/seaweedfs/weed/query/sqltypes" + "github.com/seaweedfs/seaweedfs/weed/util/version" ) // handleMessage processes a single PostgreSQL protocol message @@ -168,7 +169,7 @@ func (s *PostgreSQLServer) handleSystemQuery(session *PostgreSQLSession, query s case "select version()": return &SystemQueryResult{ Columns: []string{"version"}, - Rows: [][]string{{"SeaweedFS 1.0 (PostgreSQL 14.0 compatible)"}}, + Rows: [][]string{{fmt.Sprintf("SeaweedFS %s (PostgreSQL 14.0 compatible)", version.VERSION_NUMBER)}}, } case "select current_database()": return &SystemQueryResult{ @@ -183,7 +184,7 @@ func (s *PostgreSQLServer) handleSystemQuery(session *PostgreSQLSession, query s case "select current_setting('server_version')": return &SystemQueryResult{ Columns: []string{"server_version"}, - Rows: [][]string{{"14.0"}}, + Rows: [][]string{{fmt.Sprintf("%s (SeaweedFS)", version.VERSION_NUMBER)}}, } case "select current_setting('server_encoding')": return &SystemQueryResult{ diff --git a/weed/server/postgres/server.go b/weed/server/postgres/server.go index 1caa66823..89a8c54f5 100644 --- a/weed/server/postgres/server.go +++ b/weed/server/postgres/server.go @@ -15,6 +15,7 @@ import ( "github.com/seaweedfs/seaweedfs/weed/glog" "github.com/seaweedfs/seaweedfs/weed/query/engine" + "github.com/seaweedfs/seaweedfs/weed/util/version" ) // PostgreSQL protocol constants @@ -420,7 +421,7 @@ func (s *PostgreSQLServer) handleStartup(session *PostgreSQLSession) error { } // Send parameter status messages - err = s.sendParameterStatus(session, "server_version", "14.0 (SeaweedFS)") + err = s.sendParameterStatus(session, "server_version", fmt.Sprintf("%s (SeaweedFS)", version.VERSION_NUMBER)) if err != nil { return err }