File tree Expand file tree Collapse file tree 1 file changed +13
-3
lines changed Expand file tree Collapse file tree 1 file changed +13
-3
lines changed Original file line number Diff line number Diff line change @@ -367,14 +367,24 @@ CheckServerVersionForStreaming(PGconn *conn)
367367 minServerMajor = 903 ;
368368 maxServerMajor = PG_VERSION_NUM / 100 ;
369369 serverMajor = PQserverVersion (conn ) / 100 ;
370- if (serverMajor < minServerMajor || serverMajor > maxServerMajor )
370+ if (serverMajor < minServerMajor )
371371 {
372372 const char * serverver = PQparameterStatus (conn , "server_version" );
373373
374- fprintf (stderr , _ ("%s: incompatible server version %s; streaming is only supported with server version %s\n" ),
374+ fprintf (stderr , _ ("%s: incompatible server version %s; client does not support streaming from server versions older than %s\n" ),
375375 progname ,
376376 serverver ? serverver : "'unknown'" ,
377- "9.3 or 9.4" );
377+ "9.3" );
378+ return false;
379+ }
380+ else if (serverMajor > maxServerMajor )
381+ {
382+ const char * serverver = PQparameterStatus (conn , "server_version" );
383+
384+ fprintf (stderr , _ ("%s: incompatible server version %s; client does not support streaming from server versions newer than %s\n" ),
385+ progname ,
386+ serverver ? serverver : "'unknown'" ,
387+ PG_VERSION );
378388 return false;
379389 }
380390 return true;
You can’t perform that action at this time.
0 commit comments