From 100662d134d289b8af1e225ef5fd6542f24df252 Mon Sep 17 00:00:00 2001
From: Orange flavored banana <106858113+moonwhistle@users.noreply.github.com>
Date: Tue, 4 Nov 2025 17:45:36 +0900
Subject: [PATCH] feat(jdbc): implement setUnicodeStream method in
 JDBC4PreparedStatement

---
 .../turso/jdbc4/JDBC4PreparedStatement.java   | 28 ++++++++++++++++++-
 1 file changed, 27 insertions(+), 1 deletion(-)

diff --git a/bindings/java/src/main/java/tech/turso/jdbc4/JDBC4PreparedStatement.java b/bindings/java/src/main/java/tech/turso/jdbc4/JDBC4PreparedStatement.java
index ca7123cd7..0a698eb24 100644
--- a/bindings/java/src/main/java/tech/turso/jdbc4/JDBC4PreparedStatement.java
+++ b/bindings/java/src/main/java/tech/turso/jdbc4/JDBC4PreparedStatement.java
@@ -198,7 +198,33 @@ public final class JDBC4PreparedStatement extends JDBC4Statement implements Prep
 
   @Override
   public void setUnicodeStream(int parameterIndex, InputStream x, int length) throws SQLException {
-    // TODO
+    requireNonNull(this.statement);
+    if (x == null) {
+      this.statement.bindNull(parameterIndex);
+      return;
+    }
+    if (length < 0) {
+      throw new SQLException("setUnicodeStream length must be non-negative");
+    }
+    try {
+      byte[] buffer = new byte[length];
+      int offset = 0;
+      while (offset < length) {
+        int readBytes = x.read(buffer, offset, length - offset);
+        if (readBytes == -1) {
+          break;
+        }
+        offset += readBytes;
+      }
+      if (offset == 0) {
+        this.statement.bindNull(parameterIndex);
+      } else {
+        String text = new String(buffer, 0, offset, StandardCharsets.UTF_8);
+        this.statement.bindText(parameterIndex, text);
+      }
+    } catch (IOException ioe) {
+      throw new SQLException("Error reading Unicode stream", ioe);
+    }
   }
 
   @Override