Mercurial > hg > monetdb-java

comparison tests/OnClientTester.java @ 529:ac6331eb7175 onclient

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Add tests for io errors that occur after transfer has begun FailDownloadLate is currently disabled because it causes a hang, which triggers the watchdog and kills the test runner.
author Joeri van Ruth <joeri.van.ruth@monetdbsolutions.com>
date Thu, 26 Aug 2021 16:51:58 +0200 (2021-08-26)
parents 2d14abd1fc52
children bf47aab3aeb7
comparison
equal deleted inserted replaced
528:2d14abd1fc52 529:ac6331eb7175
577 }; 577 };
578 conn.setUploadHandler(handler); 578 conn.setUploadHandler(handler);
579 update("COPY OFFSET 2 INTO foo FROM 'banana' ON CLIENT", 2); 579 update("COPY OFFSET 2 INTO foo FROM 'banana' ON CLIENT", 2);
580 queryInt("SELECT i FROM foo WHERE t = 'three'", 3); 580 queryInt("SELECT i FROM foo WHERE t = 'three'", 3);
581 } 581 }
582
583 public void test_FailUploadLate() throws SQLException, Failure {
584 prepare();
585 conn.setUploadHandler(new MyUploadHandler(100, 50, "i don't like line 50"));
586 expectError("COPY INTO foo FROM 'banana' ON CLIENT", "i don't like");
587 assertEq("connection is closed", true, conn.isClosed());
588 }
589
590 // Disabled because it hangs, triggering the watchdog timer
591 public void testx_FailDownloadLate() throws SQLException, Failure {
592 prepare();
593 MyDownloadHandler handler = new MyDownloadHandler(200, "download refused");
594 conn.setDownloadHandler(handler);
595 update("INSERT INTO foo SELECT value as i, 'number' || value AS t FROM sys.generate_series(0, 100)", 100);
596 expectError("COPY (SELECT * FROM foo) INTO 'banana' ON CLIENT", "download refused");
597 queryInt("SELECT 42 -- check if the connection still works", 42);
598 }
599
582 } 600 }