aljaz/turso
1
0
Fork 0
mirror of https://github.com/aljazceru/turso.git synced 2026-01-13 05:04:19 +01:00
Code Issues Packages Projects Releases Wiki Activity

test(jdbc): test setAsciiStream, setBinaryStream methods (int, InputStream)

Browse Source
This commit is contained in:
Orange flavored banana
2025-11-12 14:54:40 +09:00
parent 28cd56d481
commit b701154e3b
1 changed files with 106 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

118
bindings/java/src/test/java/tech/turso/jdbc4/JDBC4PreparedStatementTest.java
View File

@@ -395,7 +395,7 @@ class JDBC4PreparedStatementTest {
}
@Test
void testSetAsciiStream_insert_and_select() throws SQLException {
void testSetAsciiStream_intLength_insert_and_select() throws SQLException {
connection.prepareStatement("CREATE TABLE test (col TEXT)").execute();
PreparedStatement stmt = connection.prepareStatement("INSERT INTO test (col) VALUES (?)");
@@ -415,7 +415,7 @@ class JDBC4PreparedStatementTest {
}
@Test
void testSetAsciiStream_nullStream() throws SQLException {
void testSetAsciiStream_intLength_nullStream() throws SQLException {
connection.prepareStatement("CREATE TABLE test (col TEXT)").execute();
PreparedStatement stmt = connection.prepareStatement("INSERT INTO test (col) VALUES (?)");
@@ -431,7 +431,7 @@ class JDBC4PreparedStatementTest {
}
@Test
void testSetAsciiStream_emptyStream() throws SQLException {
void testSetAsciiStream_intLength_emptyStream() throws SQLException {
connection.prepareStatement("CREATE TABLE test (col TEXT)").execute();
PreparedStatement stmt = connection.prepareStatement("INSERT INTO test (col) VALUES (?)");
@@ -448,7 +448,7 @@ class JDBC4PreparedStatementTest {
}
@Test
void testSetAsciiStream_negativeLength() throws SQLException {
void testSetAsciiStream_intLength_negativeLength() throws SQLException {
connection.prepareStatement("CREATE TABLE test (col TEXT)").execute();
PreparedStatement stmt = connection.prepareStatement("INSERT INTO test (col) VALUES (?)");
@@ -461,7 +461,7 @@ class JDBC4PreparedStatementTest {
}
@Test
void testSetBinaryStream_insert_and_select() throws SQLException {
void testSetBinaryStream_intLength_insert_and_select() throws SQLException {
connection.prepareStatement("CREATE TABLE test (col BLOB)").execute();
PreparedStatement stmt = connection.prepareStatement("INSERT INTO test (col) VALUES (?)");
@@ -480,7 +480,7 @@ class JDBC4PreparedStatementTest {
}
@Test
void testSetBinaryStream_nullStream() throws SQLException {
void testSetBinaryStream_intLength_nullStream() throws SQLException {
connection.prepareStatement("CREATE TABLE test (col BLOB)").execute();
PreparedStatement stmt = connection.prepareStatement("INSERT INTO test (col) VALUES (?)");
@@ -496,7 +496,7 @@ class JDBC4PreparedStatementTest {
}
@Test
void testSetBinaryStream_emptyStream() throws SQLException {
void testSetBinaryStream_intLength_emptyStream() throws SQLException {
connection.prepareStatement("CREATE TABLE test (col BLOB)").execute();
PreparedStatement stmt = connection.prepareStatement("INSERT INTO test (col) VALUES (?)");
@@ -517,7 +517,7 @@ class JDBC4PreparedStatementTest {
}
@Test
void testSetBinaryStream_negativeLength() throws SQLException {
void testSetBinaryStream_intLength_negativeLength() throws SQLException {
connection.prepareStatement("CREATE TABLE test (col BLOB)").execute();
PreparedStatement stmt = connection.prepareStatement("INSERT INTO test (col) VALUES (?)");
@@ -529,7 +529,7 @@ class JDBC4PreparedStatementTest {
}
@Test
void testSetUnicodeStream_insert_and_select() throws SQLException {
void testSetUnicodeStream_intLength_insert_and_select() throws SQLException {
connection.prepareStatement("CREATE TABLE test (col TEXT)").execute();
PreparedStatement stmt = connection.prepareStatement("INSERT INTO test (col) VALUES (?)");
@@ -549,7 +549,7 @@ class JDBC4PreparedStatementTest {
}
@Test
void testSetUnicodeStream_nullStream() throws SQLException {
void testSetUnicodeStream_intLength_nullStream() throws SQLException {
connection.prepareStatement("CREATE TABLE test (col TEXT)").execute();
PreparedStatement stmt = connection.prepareStatement("INSERT INTO test (col) VALUES (?)");
@@ -565,7 +565,7 @@ class JDBC4PreparedStatementTest {
}
@Test
void testSetUnicodeStream_emptyStream() throws SQLException {
void testSetUnicodeStream_intLength_emptyStream() throws SQLException {
connection.prepareStatement("CREATE TABLE test (col TEXT)").execute();
PreparedStatement stmt = connection.prepareStatement("INSERT INTO test (col) VALUES (?)");
@@ -582,7 +582,7 @@ class JDBC4PreparedStatementTest {
}
@Test
void testSetUnicodeStream_negativeLength() throws SQLException {
void testSetUnicodeStream_intLength_negativeLength() throws SQLException {
connection.prepareStatement("CREATE TABLE test (col TEXT)").execute();
PreparedStatement stmt = connection.prepareStatement("INSERT INTO test (col) VALUES (?)");
@@ -747,6 +747,100 @@ class JDBC4PreparedStatementTest {
() -> stmt.setBinaryStream(1, stream, (long) Integer.MAX_VALUE + 1));
}
@Test
void testSetAsciiStream_noLength_insert_and_select() throws SQLException {
connection.prepareStatement("CREATE TABLE test (col TEXT)").execute();
PreparedStatement stmt = connection.prepareStatement("INSERT INTO test (col) VALUES (?)");
String text = "test";
byte[] bytes = text.getBytes(StandardCharsets.US_ASCII);
InputStream stream = new ByteArrayInputStream(bytes);
stmt.setAsciiStream(1, stream);
stmt.execute();
PreparedStatement stmt2 = connection.prepareStatement("SELECT col FROM test");
ResultSet rs = stmt2.executeQuery();
assertTrue(rs.next());
assertEquals(text, rs.getString(1));
}
@Test
void testSetAsciiStream_noLength_nullStream() throws SQLException {
connection.prepareStatement("CREATE TABLE test (col TEXT)").execute();
PreparedStatement stmt = connection.prepareStatement("INSERT INTO test (col) VALUES (?)");
stmt.setAsciiStream(1, null);
stmt.execute();
ResultSet rs = connection.prepareStatement("SELECT col FROM test").executeQuery();
assertTrue(rs.next());
assertNull(rs.getString(1));
}
@Test
void testSetAsciiStream_noLength_emptyStream() throws SQLException {
connection.prepareStatement("CREATE TABLE test (col TEXT)").execute();
PreparedStatement stmt = connection.prepareStatement("INSERT INTO test (col) VALUES (?)");
InputStream empty = new ByteArrayInputStream(new byte[0]);
stmt.setAsciiStream(1, empty);
stmt.execute();
ResultSet rs = connection.prepareStatement("SELECT col FROM test").executeQuery();
assertTrue(rs.next());
assertEquals("", rs.getString(1));
}
@Test
void testSetBinaryStream_noLength_insert_and_select() throws SQLException {
connection.prepareStatement("CREATE TABLE test (col BLOB)").execute();
PreparedStatement stmt = connection.prepareStatement("INSERT INTO test (col) VALUES (?)");
byte[] data = {1, 2, 3, 4, 5};
InputStream stream = new ByteArrayInputStream(data);
stmt.setBinaryStream(1, stream);
stmt.execute();
PreparedStatement stmt2 = connection.prepareStatement("SELECT col FROM test");
ResultSet rs = stmt2.executeQuery();
assertTrue(rs.next());
assertArrayEquals(data, rs.getBytes(1));
}
@Test
void testSetBinaryStream_noLength_nullStream() throws SQLException {
connection.prepareStatement("CREATE TABLE test (col BLOB)").execute();
PreparedStatement stmt = connection.prepareStatement("INSERT INTO test (col) VALUES (?)");
stmt.setBinaryStream(1, null);
stmt.execute();
ResultSet rs = connection.prepareStatement("SELECT col FROM test").executeQuery();
assertTrue(rs.next());
assertNull(rs.getBytes(1));
}
@Test
void testSetBinaryStream_noLength_emptyStream() throws SQLException {
connection.prepareStatement("CREATE TABLE test (col BLOB)").execute();
PreparedStatement stmt = connection.prepareStatement("INSERT INTO test (col) VALUES (?)");
InputStream empty = new ByteArrayInputStream(new byte[0]);
stmt.setBinaryStream(1, empty);
stmt.execute();
ResultSet rs = connection.prepareStatement("SELECT col FROM test").executeQuery();
assertTrue(rs.next());
byte[] result = rs.getBytes(1);
assertNotNull(result);
assertEquals(0, result.length);
}
@Test
void execute_insert_should_return_number_of_inserted_elements() throws Exception {
connection.prepareStatement("CREATE TABLE test (col INTEGER)").execute();