You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@openjpa.apache.org by fa...@apache.org on 2010/06/16 23:28:11 UTC
svn commit: r955400 -
/openjpa/trunk/openjpa-jdbc/src/main/java/org/apache/openjpa/jdbc/sql/DB2Dictionary.java
Author: faywang
Date: Wed Jun 16 21:28:11 2010
New Revision: 955400
URL: http://svn.apache.org/viewvc?rev=955400&view=rev
Log:
OPENJPA-1699: clean up code
Modified:
openjpa/trunk/openjpa-jdbc/src/main/java/org/apache/openjpa/jdbc/sql/DB2Dictionary.java
Modified: openjpa/trunk/openjpa-jdbc/src/main/java/org/apache/openjpa/jdbc/sql/DB2Dictionary.java
URL: http://svn.apache.org/viewvc/openjpa/trunk/openjpa-jdbc/src/main/java/org/apache/openjpa/jdbc/sql/DB2Dictionary.java?rev=955400&r1=955399&r2=955400&view=diff
==============================================================================
--- openjpa/trunk/openjpa-jdbc/src/main/java/org/apache/openjpa/jdbc/sql/DB2Dictionary.java (original)
+++ openjpa/trunk/openjpa-jdbc/src/main/java/org/apache/openjpa/jdbc/sql/DB2Dictionary.java Wed Jun 16 21:28:11 2010
@@ -1036,39 +1036,34 @@ public class DB2Dictionary
}
}
}
-
+
+ @Override
public void insertBlobForStreamingLoad(Row row, Column col,
JDBCStore store, Object ob, Select sel) throws SQLException {
if (ob != null) {
- if (ob instanceof InputStream) {
- InputStream is = (InputStream)ob;
- row.setBinaryStream(col, is, -1);
- } else
- row.setBinaryStream(col,
- new ByteArrayInputStream(new byte[0]), 0);
+ row.setBinaryStream(col, (InputStream)ob, -1);
} else {
row.setNull(col);
}
}
+ @Override
public void insertClobForStreamingLoad(Row row, Column col, Object ob)
throws SQLException {
if (ob != null) {
- if (ob instanceof Reader) {
- row.setCharacterStream(col, (Reader)ob, -1);
- } else
- row.setCharacterStream(col,
- new CharArrayReader(new char[0]), 0);
+ row.setCharacterStream(col, (Reader)ob, -1);
} else {
row.setNull(col);
}
}
+ @Override
public void updateBlob(Select sel, JDBCStore store, InputStream is)
throws SQLException {
//NO-OP
}
+ @Override
public void updateClob(Select sel, JDBCStore store, Reader reader)
throws SQLException {
//NO-OP