Person person; // 需要插入的Person对象
InputStream input; // Person应该插入的Photo，通过网页上传获得，将插入image类型字段
Connection conn = new Connection(); // 实际的Connection对象
PreparedStatement stmt = null;
ResultSet rs = null;
String sql= null;
conn.setAutoCommit(false); // 设置 auto commit = false;
sql = "insert into person (id, name) values (?, ?)"; // 插入Person的其它字段
stmt = conn.prepareStatement(sql);
stmt.setInt(1, person.id);
stmt.setString(2, person.name);
stmt.executeUpdate();
sql = "update person set photo = null where id = ?"; // 初始化image数据类型的指针
// 即使在insert时插入image类型的值为null，数据库依然不会创建指针。可以使用update创建指针。
stmt = conn.prepareStatement(sql);
stmt.setInt(1, person.id);
stmt.executeUpdate();
sql = "select textptr(photo) from person where id = ?"; // 获得image类型的指针
stmt = conn.prepareStatement(sql);
stmt.setInt(1, person.id);
rs = stmt.executeQuery(sql);
if (rs.next())
{
byte[] ptr = rs.getBytes(1); // ptr：image类型的指针
sql = "updatetext person.photo ? ? 0 ?"; // 更新image类型字段，0表示不删除内容
stmt = conn.prepareStatement(sql);
int offset = 0;
int len = 0;
byte[] buffer = new byte[10*1024]; // 读写缓冲区
while ((len = input.read(buffer)) != -1) // 读取input流，-1表示已经读完
{
stmt.setBytes(1, ptr); // image类型的指针
stmt.setInt(2, offset); // 偏移量
stmt.setBytes(3, buffer); // 读入的内容
stmt.executeUpdate(); // 将读取内容写入数据库
stmt.clearParameters();
offset += len; // 移动偏移量
}
sql = "updatetext person.photo ? ? NULL"; // 删除多余内容，0表示偏移量后所有内容
stmt = conn.prepareStatement(sql);
stmt.setBytes(1, ptr);
stmt.setInt(2, offset); // 终点的偏移量
stmt.executeUpdate();
input.close(); // 关闭输入流
}
conn.commit(); // commit connection