Mercurial > hg > monetdb-java

comparison tests/OnClientTester.java @ 528:2d14abd1fc52 onclient

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Improve test names
author Joeri van Ruth <joeri.van.ruth@monetdbsolutions.com>
date Thu, 26 Aug 2021 16:50:56 +0200 (2021-08-26)
parents ccf9c7fbdb50
children ac6331eb7175
comparison
equal deleted inserted replaced
527:ccf9c7fbdb50 528:2d14abd1fc52
451 conn.setUploadHandler(new MyUploadHandler(100)); 451 conn.setUploadHandler(new MyUploadHandler(100));
452 update("COPY INTO foo FROM 'banana' ON CLIENT", 100); 452 update("COPY INTO foo FROM 'banana' ON CLIENT", 100);
453 queryInt("SELECT COUNT(*) FROM foo", 100); 453 queryInt("SELECT COUNT(*) FROM foo", 100);
454 } 454 }
455 455
456 public void test_ClientRefuses() throws Exception { 456 public void test_ClientRefusesUpload() throws Exception {
457 prepare(); 457 prepare();
458 conn.setUploadHandler(new MyUploadHandler("immediate error")); 458 conn.setUploadHandler(new MyUploadHandler("immediate error"));
459 expectError("COPY INTO foo FROM 'banana' ON CLIENT", "immediate error"); 459 expectError("COPY INTO foo FROM 'banana' ON CLIENT", "immediate error");
460 queryInt("SELECT COUNT(*) FROM foo", 0); 460 queryInt("SELECT COUNT(*) FROM foo", 0);
461 } 461 }
482 update("COPY OFFSET 5 INTO foo FROM 'banana' ON CLIENT", 96); 482 update("COPY OFFSET 5 INTO foo FROM 'banana' ON CLIENT", 96);
483 queryInt("SELECT MIN(i) FROM foo", 5); 483 queryInt("SELECT MIN(i) FROM foo", 5);
484 queryInt("SELECT MAX(i) FROM foo", 100); 484 queryInt("SELECT MAX(i) FROM foo", 100);
485 } 485 }
486 486
487 public void testx_ServerCancels() throws SQLException, Failure { 487 public void test_ServerStopsReading() throws SQLException, Failure {
488 prepare(); 488 prepare();
489 conn.setUploadHandler(new MyUploadHandler(100)); 489 conn.setUploadHandler(new MyUploadHandler(100));
490 update("COPY 10 RECORDS INTO foo FROM 'banana' ON CLIENT", 96); 490 update("COPY 10 RECORDS INTO foo FROM 'banana' ON CLIENT", 96);
491 // Server stopped reading after 10 rows. Will we stay in sync? 491 // Server stopped reading after 10 rows. Will we stay in sync?
492 queryInt("SELECT COUNT(i) FROM foo", 10); 492 queryInt("SELECT COUNT(i) FROM foo", 10);
505 505
506 public void test_Download() throws SQLException, Failure { 506 public void test_Download() throws SQLException, Failure {
507 test_Download(100); 507 test_Download(100);
508 } 508 }
509 509
510 public void test_CancelledDownload() throws SQLException, Failure { 510 public void test_ClientRefusesDownload() throws SQLException, Failure {
511 prepare(); 511 prepare();
512 MyDownloadHandler handler = new MyDownloadHandler("download refused"); 512 MyDownloadHandler handler = new MyDownloadHandler("download refused");
513 conn.setDownloadHandler(handler); 513 conn.setDownloadHandler(handler);
514 update("INSERT INTO foo SELECT value as i, 'number' || value AS t FROM sys.generate_series(0, 100)", 100); 514 update("INSERT INTO foo SELECT value as i, 'number' || value AS t FROM sys.generate_series(0, 100)", 100);
515 expectError("COPY (SELECT * FROM foo) INTO 'banana' ON CLIENT", "download refused"); 515 expectError("COPY (SELECT * FROM foo) INTO 'banana' ON CLIENT", "download refused");