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

refactor(jdbc): Added early return for length == 0 and improved read loop condition in setUnicodeStream and setAsciiStream

Browse Source
This commit is contained in:
Orange flavored banana
2025-11-06 10:13:23 +09:00
parent b75e4b5a19
commit 510b8ef59f
1 changed files with 17 additions and 23 deletions
Download Patch File Download Diff File Expand all files Collapse all files

40
bindings/java/src/main/java/tech/turso/jdbc4/JDBC4PreparedStatement.java
View File

@@ -175,22 +175,19 @@ public final class JDBC4PreparedStatement extends JDBC4Statement implements Prep
if (length < 0) {
throw new SQLException("setAsciiStream length must be non-negative");
}
if (length == 0) {
this.statement.bindText(parameterIndex, "");
return;
}
try {
byte[] buffer = new byte[length];
int offset = 0;
while (offset < length) {
int read = x.read(buffer, offset, length - offset);
if (read == -1) {
break;
}
int read;
while (offset < length && (read = x.read(buffer, offset, length - offset)) > 0) {
offset += read;
}
if (offset == 0) {
this.statement.bindText(parameterIndex, "");
} else {
String ascii = new String(buffer, 0, offset, StandardCharsets.US_ASCII);
this.statement.bindText(parameterIndex, ascii);
}
String ascii = new String(buffer, 0, offset, StandardCharsets.US_ASCII);
this.statement.bindText(parameterIndex, ascii);
} catch (IOException e) {
throw new SQLException("Error reading ASCII stream", e);
}
@@ -206,22 +203,19 @@ public final class JDBC4PreparedStatement extends JDBC4Statement implements Prep
if (length < 0) {
throw new SQLException("setUnicodeStream length must be non-negative");
}
if (length == 0) {
this.statement.bindText(parameterIndex, "");
return;
}
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.bindText(parameterIndex, "");
} else {
String text = new String(buffer, 0, offset, StandardCharsets.UTF_8);
this.statement.bindText(parameterIndex, text);
int read;
while (offset < length && (read = x.read(buffer, offset, length - offset)) > 0) {
offset += read;
}
String text = new String(buffer, 0, offset, StandardCharsets.UTF_8);
this.statement.bindText(parameterIndex, text);
} catch (IOException e) {
throw new SQLException("Error reading Unicode stream", e);
}