aljaz/turso
1
0
Fork 0
mirror of https://github.com/aljazceru/turso.git synced 2026-01-28 12:24:23 +01:00
Code Issues Packages Projects Releases Wiki Activity

feat(jdbc): test setUnicodeStream method in JDBC4PreparedStatementTest

Browse Source
This commit is contained in:
Orange flavored banana
2025-11-04 17:48:31 +09:00
parent 100662d134
commit 52f8c1a33e
1 changed files with 66 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -523,6 +523,72 @@ class JDBC4PreparedStatementTest {
assertThrows(SQLException.class, () -> stmt.setBinaryStream(1, stream, -1));
}
@Test
void testSetUnicodeStream_insert_and_select() throws SQLException {
connection.prepareStatement("CREATE TABLE test (col TEXT)").execute();
PreparedStatement stmt = connection.prepareStatement("INSERT INTO test (col) VALUES (?)");
String text = "안녕하세요😊 Hello🌏";
byte[] bytes = text.getBytes(StandardCharsets.UTF_8);
InputStream stream = new ByteArrayInputStream(bytes);
stmt.setUnicodeStream(1, stream, bytes.length);
stmt.execute();
PreparedStatement stmt2 = connection.prepareStatement("SELECT col FROM test");
ResultSet rs = stmt2.executeQuery();
assertTrue(rs.next());
assertEquals(text, rs.getString(1));
}
@Test
void testSetUnicodeStream_nullStream() throws SQLException {
connection.prepareStatement("CREATE TABLE test (col TEXT)").execute();
PreparedStatement stmt = connection.prepareStatement("INSERT INTO test (col) VALUES (?)");
stmt.setUnicodeStream(1, null, 0);
stmt.execute();
PreparedStatement stmt2 = connection.prepareStatement("SELECT col FROM test");
ResultSet rs = stmt2.executeQuery();
assertTrue(rs.next());
assertNull(rs.getString(1));
}
@Test
void testSetUnicodeStream_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.setUnicodeStream(1, empty, 10);
stmt.execute();
PreparedStatement stmt2 = connection.prepareStatement("SELECT col FROM test");
ResultSet rs = stmt2.executeQuery();
assertTrue(rs.next());
assertNull(rs.getString(1));
}
@Test
void testSetUnicodeStream_negativeLength() throws SQLException {
connection.prepareStatement("CREATE TABLE test (col TEXT)").execute();
PreparedStatement stmt = connection.prepareStatement("INSERT INTO test (col) VALUES (?)");
String text = "테스트";
byte[] bytes = text.getBytes(StandardCharsets.UTF_8);
InputStream stream = new ByteArrayInputStream(bytes);
assertThrows(SQLException.class, () -> stmt.setUnicodeStream(1, stream, -5));
}
@Test
void execute_insert_should_return_number_of_inserted_elements() throws Exception {
connection.prepareStatement("CREATE TABLE test (col INTEGER)").execute();