From 27233a947fe34e6b7923b556fd80375ea81ec494 Mon Sep 17 00:00:00 2001
From: kimminseok <alstjr706@naver.com>
Date: Sun, 26 Oct 2025 22:34:43 +0900
Subject: [PATCH] Add consistent wasNull handling for stream getter methods

---
 .../java/tech/turso/jdbc4/JDBC4ResultSet.java | 49 ++++++++++++++++---
 1 file changed, 42 insertions(+), 7 deletions(-)

diff --git a/bindings/java/src/main/java/tech/turso/jdbc4/JDBC4ResultSet.java b/bindings/java/src/main/java/tech/turso/jdbc4/JDBC4ResultSet.java
index b10e28be5..8c440177f 100644
--- a/bindings/java/src/main/java/tech/turso/jdbc4/JDBC4ResultSet.java
+++ b/bindings/java/src/main/java/tech/turso/jdbc4/JDBC4ResultSet.java
@@ -1,5 +1,6 @@
 package tech.turso.jdbc4;
 
+import java.io.ByteArrayInputStream;
 import java.io.InputStream;
 import java.io.Reader;
 import java.io.StringReader;
@@ -49,7 +50,7 @@ public final class JDBC4ResultSet implements ResultSet, ResultSetMetaData {
 
   @Override
   public boolean wasNull() throws SQLException {
-    throw new UnsupportedOperationException("not implemented");
+    return wasNull;
   }
 
   @Override
@@ -224,19 +225,53 @@ public final class JDBC4ResultSet implements ResultSet, ResultSetMetaData {
   @Override
   @SkipNullableCheck
   public InputStream getAsciiStream(int columnIndex) throws SQLException {
-    throw new UnsupportedOperationException("not implemented");
+    final Object result = resultSet.get(columnIndex);
+    wasNull = result == null;
+    if (result == null) {
+      return null;
+    }
+    return wrapTypeConversion(() -> {
+      if (result instanceof String) {
+        return new ByteArrayInputStream(((String) result).getBytes("US-ASCII"));
+      } else if (result instanceof byte[]) {
+        return new ByteArrayInputStream((byte[]) result);
+      }
+      throw new SQLException("Cannot convert to ASCII stream: " + result.getClass());
+    });
   }
 
   @Override
   @SkipNullableCheck
   public InputStream getUnicodeStream(int columnIndex) throws SQLException {
-    throw new UnsupportedOperationException("not implemented");
+    final Object result = resultSet.get(columnIndex);
+    wasNull = result == null;
+    if (result == null) {
+      return null;
+    }
+    return wrapTypeConversion(() -> {
+      if (result instanceof String) {
+        return new ByteArrayInputStream(((String) result).getBytes("UTF-8"));
+      } else if (result instanceof byte[]) {
+        return new ByteArrayInputStream((byte[]) result);
+      }
+      throw new SQLException("Cannot convert to Unicode stream: " + result.getClass());
+    });
   }
 
   @Override
   @SkipNullableCheck
   public InputStream getBinaryStream(int columnIndex) throws SQLException {
-    throw new UnsupportedOperationException("not implemented");
+    final Object result = resultSet.get(columnIndex);
+    wasNull = result == null;
+    if (result == null) {
+      return null;
+    }
+    return wrapTypeConversion(() -> {
+      if (result instanceof byte[]) {
+        return new ByteArrayInputStream((byte[]) result);
+      }
+      throw new SQLException("Cannot convert to binary stream: " + result.getClass());
+    });
   }
 
   @Override
@@ -332,19 +367,19 @@ public final class JDBC4ResultSet implements ResultSet, ResultSetMetaData {
   @Override
   @SkipNullableCheck
   public InputStream getAsciiStream(String columnLabel) throws SQLException {
-    throw new UnsupportedOperationException("not implemented");
+    return getAsciiStream(findColumn(columnLabel));
   }
 
   @Override
   @SkipNullableCheck
   public InputStream getUnicodeStream(String columnLabel) throws SQLException {
-    throw new UnsupportedOperationException("not implemented");
+    return getUnicodeStream(findColumn(columnLabel));
   }
 
   @Override
   @SkipNullableCheck
   public InputStream getBinaryStream(String columnLabel) throws SQLException {
-    throw new UnsupportedOperationException("not implemented");
+    return getBinaryStream(findColumn(columnLabel));
   }
 
   @Override