/*
 *
 * MariaDB Client for Java
 *
 * Copyright (c) 2012-2014 Monty Program Ab.
 * Copyright (c) 2015-2020 MariaDB Corporation Ab.
 *
 * This library is free software; you can redistribute it and/or modify it under
 * the terms of the GNU Lesser General Public License as published by the Free
 * Software Foundation; either version 2.1 of the License, or (at your option)
 * any later version.
 *
 * This library is distributed in the hope that it will be useful, but
 * WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
 * FITNESS FOR A PARTICULAR PURPOSE.  See the GNU Lesser General Public License
 * for more details.
 *
 * You should have received a copy of the GNU Lesser General Public License along
 * with this library; if not, write to Monty Program Ab info@montyprogram.com.
 *
 * This particular MariaDB Client for Java file is work
 * derived from a Drizzle-JDBC. Drizzle-JDBC file which is covered by subject to
 * the following copyright and notice provisions:
 *
 * Copyright (c) 2009-2011, Marcus Eriksson
 *
 * Redistribution and use in source and binary forms, with or without modification,
 * are permitted provided that the following conditions are met:
 * Redistributions of source code must retain the above copyright notice, this list
 * of conditions and the following disclaimer.
 *
 * Redistributions in binary form must reproduce the above copyright notice, this
 * list of conditions and the following disclaimer in the documentation and/or
 * other materials provided with the distribution.
 *
 * Neither the name of the driver nor the names of its contributors may not be
 * used to endorse or promote products derived from this software without specific
 * prior written permission.
 *
 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS  AND CONTRIBUTORS "AS IS"
 * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
 * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
 * IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT,
 * INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
 * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR
 * PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY,
 * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
 * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY
 * OF SUCH DAMAGE.
 *
 */

package org.mariadb.jdbc;

import static org.junit.Assert.*;

import java.io.*;
import java.lang.reflect.Field;
import java.lang.reflect.Method;
import java.lang.reflect.Proxy;
import java.sql.*;
import java.util.Arrays;
import java.util.Random;
import org.junit.AfterClass;
import org.junit.Assume;
import org.junit.BeforeClass;
import org.junit.Test;

public class BlobTest extends BaseTest {

  /**
   * Initialisation.
   *
   * @throws SQLException exception
   */
  @BeforeClass()
  public static void initClass() throws SQLException {
    try (Statement stmt = sharedConnection.createStatement()) {
      stmt.execute(
          "CREATE TABLE bug716378(id int not null primary key auto_increment, test longblob, test2 blob, test3 text)");
      stmt.execute(
          "CREATE TABLE BlobTeststreamtest2(id int primary key not null, st varchar(20), strm text, strm2 text, strm3 text) CHARSET utf8");
      stmt.execute(
          "CREATE TABLE BlobTeststreamtest3(id int primary key not null, strm text) CHARSET utf8");
      stmt.execute(
          "CREATE TABLE BlobTestclobtest(id int not null primary key, strm text) CHARSET utf8");
      stmt.execute("CREATE TABLE BlobTestclobtest2(strm text) CHARSET utf8");
      stmt.execute(
          "CREATE TABLE BlobTestclobtest3(id int not null primary key, strm text) CHARSET utf8");
      stmt.execute(
          "CREATE TABLE BlobTestclobtest4(id int not null primary key, strm text) CHARSET utf8");
      stmt.execute(
          "CREATE TABLE BlobTestclobtest5(id int not null primary key, strm text) CHARSET utf8");
      stmt.execute("CREATE TABLE BlobTestblobtest(id int not null primary key, strm blob)");
      stmt.execute("CREATE TABLE BlobTestblobtest2(id int not null primary key, strm blob)");
      stmt.execute(
          "CREATE TABLE conj77_test(Name VARCHAR(100) NOT NULL,Archive LONGBLOB, PRIMARY KEY (Name)) Engine=InnoDB DEFAULT CHARSET utf8");
      stmt.execute("CREATE TABLE emptyBlob(test longblob, test2 text, test3 text)");
      stmt.execute("FLUSH TABLES");
    }
  }

  @AfterClass
  public static void afterClass() throws SQLException {
    try (Statement stmt = sharedConnection.createStatement()) {
      stmt.execute("DROP TABLE bug716378");
      stmt.execute("DROP TABLE BlobTeststreamtest2");
      stmt.execute("DROP TABLE BlobTeststreamtest3");
      stmt.execute("DROP TABLE BlobTestclobtest");
      stmt.execute("DROP TABLE BlobTestclobtest2");
      stmt.execute("DROP TABLE BlobTestclobtest3");
      stmt.execute("DROP TABLE BlobTestclobtest4");
      stmt.execute("DROP TABLE BlobTestclobtest5");
      stmt.execute("DROP TABLE BlobTestblobtest");
      stmt.execute("DROP TABLE BlobTestblobtest2");
      stmt.execute("DROP TABLE conj77_test");
      stmt.execute("DROP TABLE emptyBlob");
    }
  }

  @Test
  public void testPosition() throws SQLException {
    byte[] blobContent = new byte[] {1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12};
    byte[] pattern = new byte[] {3, 4};
    Blob blob = new MariaDbBlob(blobContent);
    assertEquals(3, blob.position(pattern, 1));
    pattern = new byte[] {12, 13};
    assertEquals(-1, blob.position(pattern, 1));
    pattern = new byte[] {11, 12};
    assertEquals(11, blob.position(pattern, 1));
    pattern = new byte[] {1, 2};
    assertEquals(1, blob.position(pattern, 1));
  }

  @Test(expected = SQLException.class)
  public void testBadStart() throws SQLException {
    byte[] blobContent = new byte[] {1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12};
    byte[] pattern = new byte[] {3, 4};
    Blob blob = new MariaDbBlob(blobContent);
    blob.position(pattern, 0);
  }

  @Test(expected = SQLException.class)
  public void testBadStart2() throws SQLException {
    byte[] blobContent = new byte[] {1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12};
    byte[] pattern = new byte[] {3, 4};
    Blob blob = new MariaDbBlob(blobContent);
    blob.position(pattern, 44);
  }

  @Test
  public void testBug716378() throws SQLException {
    Statement stmt = sharedConnection.createStatement();

    stmt.executeUpdate("insert into bug716378 values(null, 'a','b','c')");
    ResultSet rs = stmt.executeQuery("select * from bug716378");
    assertTrue(rs.next());
    byte[] arr = new byte[0];
    assertEquals(arr.getClass(), rs.getObject(2).getClass());
    assertEquals(arr.getClass(), rs.getObject(3).getClass());
    assertEquals(String.class, rs.getObject(4).getClass());
  }

  @Test
  public void testCharacterStreamWithMultibyteCharacterAndLength() throws Throwable {
    String toInsert1 = "Øbbcdefgh\njklmn\"";
    String toInsert2 = "Øabcdefgh\njklmn\"";
    PreparedStatement stmt =
        sharedConnection.prepareStatement(
            "insert into BlobTeststreamtest2 (id, st, strm, strm2, strm3) values (?,?,?,?,?)");
    stmt.setInt(1, 2);
    stmt.setString(2, toInsert1);
    Reader reader = new StringReader(toInsert2);
    stmt.setCharacterStream(3, reader, 5);
    stmt.setCharacterStream(4, null);
    stmt.setCharacterStream(5, null, 5);
    stmt.execute();

    ResultSet rs =
        sharedConnection.createStatement().executeQuery("select * from BlobTeststreamtest2");
    assertTrue(rs.next());
    Reader rdr = rs.getCharacterStream("strm");
    StringBuilder sb = new StringBuilder();
    int ch;
    while ((ch = rdr.read()) != -1) {
      sb.append((char) ch);
    }
    assertEquals(toInsert1, rs.getString(2));
    assertEquals(toInsert2.substring(0, 5), sb.toString());
    assertNull(rs.getString(4));
    assertNull(rs.getString(5));
  }

  @Test
  public void testCharacterStreamWithMultibyteCharacter() throws Throwable {
    PreparedStatement stmt =
        sharedConnection.prepareStatement(
            "insert into BlobTeststreamtest3 (id, strm) values (?,?)");
    stmt.setInt(1, 2);
    String toInsert = "Øabcdefgh\njklmn\"";
    Reader reader = new StringReader(toInsert);
    stmt.setCharacterStream(2, reader);
    stmt.execute();
    ResultSet rs =
        sharedConnection.createStatement().executeQuery("select * from BlobTeststreamtest3");
    assertTrue(rs.next());
    Reader rdr = rs.getCharacterStream("strm");
    StringBuilder sb = new StringBuilder();
    int ch;
    while ((ch = rdr.read()) != -1) {
      sb.append((char) ch);
    }
    assertEquals(toInsert, sb.toString());
  }

  @Test
  public void testReaderWithLength() throws SQLException, IOException {
    PreparedStatement stmt =
        sharedConnection.prepareStatement("insert into BlobTestclobtest5 (id, strm) values (?,?)");
    byte[] arr = new byte[32000];
    Arrays.fill(arr, (byte) 'b');

    stmt.setInt(1, 1);
    String clob = new String(arr);
    stmt.setCharacterStream(2, new StringReader(clob), 20000);
    stmt.execute();
    ResultSet rs =
        sharedConnection.createStatement().executeQuery("select * from BlobTestclobtest5");
    assertTrue(rs.next());
    Reader readStuff = rs.getCharacterStream("strm");

    char[] chars = new char[50000];
    //noinspection ResultOfMethodCallIgnored
    readStuff.read(chars);

    byte[] arrResult = new byte[20000];
    Arrays.fill(arrResult, (byte) 'b');

    for (int i = 0; i < chars.length; i++) {
      if (i < 20000) {
        assertEquals(arrResult[i], chars[i]);
      } else {
        assertEquals(chars[i], '\u0000');
      }
    }
  }

  @Test
  public void testBlobWithLength() throws SQLException, IOException {
    PreparedStatement stmt =
        sharedConnection.prepareStatement("insert into BlobTestblobtest2 (id, strm) values (?,?)");
    byte[] arr = new byte[32000];
    Random rand = new Random();
    rand.nextBytes(arr);
    InputStream stream = new ByteArrayInputStream(arr);
    stmt.setInt(1, 1);
    stmt.setBlob(2, stream, 20000);
    stmt.execute();

    // check what stream not read after length:
    int remainRead = 0;
    while (stream.read() >= 0) {
      remainRead++;
    }
    assertEquals(12000, remainRead);

    ResultSet rs =
        sharedConnection.createStatement().executeQuery("select * from BlobTestblobtest2");
    assertTrue(rs.next());
    InputStream readStuff = rs.getBlob("strm").getBinaryStream();
    int pos = 0;
    int ch;
    while ((ch = readStuff.read()) != -1) {
      assertEquals(arr[pos++] & 0xff, ch);
    }
    assertEquals(20000, pos);
  }

  @Test
  public void testClobWithLengthAndMultibyteCharacter() throws SQLException, IOException {
    PreparedStatement stmt =
        sharedConnection.prepareStatement("insert into BlobTestclobtest (id, strm) values (?,?)");
    String clob = "Øclob";
    stmt.setInt(1, 1);
    stmt.setClob(2, new StringReader(clob));
    stmt.execute();
    ResultSet rs =
        sharedConnection.createStatement().executeQuery("select * from BlobTestclobtest");
    if (rs.next()) {
      Reader readStuff = rs.getClob("strm").getCharacterStream();
      char[] chars = new char[5];
      //noinspection ResultOfMethodCallIgnored
      readStuff.read(chars);
      assertEquals(new String(chars), clob);
    } else {
      fail();
    }
  }

  @Test
  public void testClob3() throws Exception {
    PreparedStatement stmt =
        sharedConnection.prepareStatement("insert into BlobTestclobtest2 (strm) values (?)");
    Clob clob = sharedConnection.createClob();
    Writer writer = clob.setCharacterStream(1);
    writer.write("Øhello", 0, 6);
    writer.flush();
    stmt.setClob(1, clob);
    stmt.execute();
    ResultSet rs =
        sharedConnection.createStatement().executeQuery("select * from BlobTestclobtest2");
    assertTrue(rs.next());
    assertTrue(rs.getObject(1) instanceof String);
    String result = rs.getString(1);
    assertEquals("Øhello", result);
  }

  @Test
  public void testBlob() throws SQLException, IOException {
    PreparedStatement stmt =
        sharedConnection.prepareStatement("insert into BlobTestblobtest (id, strm) values (?,?)");
    byte[] theBlob = {1, 2, 3, 4, 5, 6};
    InputStream stream = new ByteArrayInputStream(theBlob);
    stmt.setInt(1, 1);
    stmt.setBlob(2, stream);
    stmt.execute();
    ResultSet rs =
        sharedConnection.createStatement().executeQuery("select * from BlobTestblobtest");
    assertTrue(rs.next());
    InputStream readStuff = rs.getBlob("strm").getBinaryStream();
    int ch;
    int pos = 0;
    while ((ch = readStuff.read()) != -1) {
      assertEquals(theBlob[pos++], ch);
    }

    readStuff = rs.getBinaryStream("strm");

    pos = 0;
    while ((ch = readStuff.read()) != -1) {
      assertEquals(theBlob[pos++], ch);
    }
  }

  @Test
  public void testClobWithLength() throws SQLException, IOException {
    PreparedStatement stmt =
        sharedConnection.prepareStatement("insert into BlobTestclobtest3 (id, strm) values (?,?)");
    String clob = "clob";
    stmt.setInt(1, 1);
    stmt.setClob(2, new StringReader(clob));
    stmt.execute();
    ResultSet rs =
        sharedConnection.createStatement().executeQuery("select * from BlobTestclobtest3");
    assertTrue(rs.next());
    Reader readStuff = rs.getClob("strm").getCharacterStream();
    char[] chars = new char[4];
    //noinspection ResultOfMethodCallIgnored
    readStuff.read(chars);
    assertEquals(new String(chars), clob);
  }

  @Test
  public void testClob2() throws SQLException, IOException {
    PreparedStatement stmt =
        sharedConnection.prepareStatement("insert into BlobTestclobtest4 (id, strm) values (?,?)");
    Clob clob = sharedConnection.createClob();
    OutputStream ostream = clob.setAsciiStream(1);
    byte[] bytes = "hello".getBytes();
    ostream.write(bytes);
    stmt.setInt(1, 1);
    stmt.setClob(2, clob);
    stmt.execute();
    ResultSet rs =
        sharedConnection.createStatement().executeQuery("select * from BlobTestclobtest4");
    assertTrue(rs.next());
    assertTrue(rs.getObject(2) instanceof String);
    assertTrue(rs.getString(2).equals("hello"));
  }

  @Test
  public void blobSerialization() throws Exception {
    Blob blob = new MariaDbBlob(new byte[] {1, 2, 3});
    ByteArrayOutputStream baos = new ByteArrayOutputStream();
    ObjectOutputStream oos = new ObjectOutputStream(baos);
    oos.writeObject(blob);

    ObjectInputStream ois = new ObjectInputStream(new ByteArrayInputStream(baos.toByteArray()));
    MariaDbBlob blob2 = (MariaDbBlob) ois.readObject();
    byte[] blobBytes = blob2.getBytes(1, (int) blob2.length());
    assertEquals(3, blobBytes.length);
    assertEquals(1, blobBytes[0]);
    assertEquals(2, blobBytes[1]);
    assertEquals(3, blobBytes[2]);

    Clob clob = new MariaDbClob(new byte[] {1, 2, 3});
    baos = new ByteArrayOutputStream();
    oos = new ObjectOutputStream(baos);
    oos.writeObject(clob);

    ois = new ObjectInputStream(new ByteArrayInputStream(baos.toByteArray()));
    MariaDbClob c2 = (MariaDbClob) ois.readObject();
    blobBytes = c2.getBytes(1, (int) c2.length());
    assertEquals(3, blobBytes.length);
    assertEquals(1, blobBytes[0]);
    assertEquals(2, blobBytes[1]);
    assertEquals(3, blobBytes[2]);
  }

  @Test
  public void conj73() throws Exception {
    /* CONJ-73: Assertion error: UTF8 length calculation reports invalid ut8 characters */
    Clob clob =
        new MariaDbClob(
            new byte[] {
              (byte) 0x10, (byte) 0xD0, (byte) 0xA0, (byte) 0xe0, (byte) 0xa1, (byte) 0x8e
            });
    ByteArrayOutputStream baos = new ByteArrayOutputStream();
    ObjectOutputStream oos = new ObjectOutputStream(baos);
    oos.writeObject(clob);

    ObjectInputStream ois = new ObjectInputStream(new ByteArrayInputStream(baos.toByteArray()));
    MariaDbClob c2 = (MariaDbClob) ois.readObject();

    assertEquals(3, c2.length());
  }

  @Test
  public void conj77() throws Exception {

    byte[][] values = new byte[3][];
    values[0] = "".getBytes();
    values[1] = "hello".getBytes();
    values[2] = null;

    try (Statement sta1 = sharedConnection.createStatement()) {
      try (PreparedStatement pre =
          sharedConnection.prepareStatement(
              "INSERT INTO conj77_test (Name,Archive) VALUES (?,?)")) {
        pre.setString(1, "1-Empty String");
        pre.setBytes(2, values[0]);
        pre.addBatch();

        pre.setString(1, "2-Data Hello");
        pre.setBytes(2, values[1]);
        pre.addBatch();

        pre.setString(1, "3-Empty Data null");
        pre.setBytes(2, values[2]);
        pre.addBatch();

        pre.executeBatch();
      }
    }

    try (Statement sta2 = sharedConnection.createStatement()) {
      try (ResultSet set = sta2.executeQuery("Select name,archive as text FROM conj77_test")) {
        int pos = 0;
        while (set.next()) {
          final Blob blob = set.getBlob("text");
          if (blob != null) {

            try (ByteArrayOutputStream bout = new ByteArrayOutputStream((int) blob.length())) {
              try (InputStream bin = blob.getBinaryStream()) {
                final byte[] buffer = new byte[1024 * 4];
                for (int read = bin.read(buffer); read != -1; read = bin.read(buffer)) {
                  bout.write(buffer, 0, read);
                }
              }
              byte[] expected = values[pos++];
              assertEquals(expected.length, bout.toByteArray().length);
              assertArrayEquals(expected, bout.toByteArray());
            }
          } else {
            assertNull(values[pos++]);
          }
        }
        assertEquals(pos, 3);
      }
    }
  }

  @Test
  public void sendEmptyBlobPreparedQuery() throws SQLException {
    try (Connection conn = setConnection()) {
      PreparedStatement ps = conn.prepareStatement("insert into emptyBlob values(?,?,?)");
      ps.setBlob(1, new MariaDbBlob(new byte[0]));
      ps.setString(2, "a 'a ");
      ps.setNull(3, Types.VARCHAR);
      ps.executeUpdate();

      Statement stmt = conn.createStatement();
      ResultSet rs = stmt.executeQuery("select * from emptyBlob");
      assertTrue(rs.next());
      assertEquals(0, rs.getBytes(1).length);
      assertEquals("a 'a ", rs.getString(2));
      assertNull(rs.getBytes(3));
    }
  }

  @Test
  public void blobSerializationWithOffset() throws Exception {
    Blob blob = new MariaDbBlob(new byte[] {1, 2, 3, 4, 5}, 1, 2);
    ByteArrayOutputStream baos = new ByteArrayOutputStream();
    ObjectOutputStream oos = new ObjectOutputStream(baos);
    oos.writeObject(blob);

    ObjectInputStream ois = new ObjectInputStream(new ByteArrayInputStream(baos.toByteArray()));
    MariaDbBlob blob2 = (MariaDbBlob) ois.readObject();
    byte[] blobBytes = blob2.getBytes(1, (int) blob2.length());
    assertEquals(2, blobBytes.length);
    assertEquals(2, blobBytes[0]);
    assertEquals(3, blobBytes[1]);

    Clob clob = new MariaDbClob(new byte[] {1, 2, 3, 4, 5}, 1, 2);
    baos = new ByteArrayOutputStream();
    oos = new ObjectOutputStream(baos);
    oos.writeObject(clob);

    ois = new ObjectInputStream(new ByteArrayInputStream(baos.toByteArray()));
    MariaDbClob c2 = (MariaDbClob) ois.readObject();
    blobBytes = c2.getBytes(1, (int) c2.length());
    assertEquals(2, blobBytes.length);
    assertEquals(2, blobBytes[0]);
    assertEquals(3, blobBytes[1]);
  }

  @Test
  public void blobDeserializationFilter() throws Exception {
    blobDeserializationFilterInternal(false, 0);
    if (System.getProperty("java.version").startsWith("9.")) {
      blobDeserializationFilterInternal(true, 2000);
      try {
        blobDeserializationFilterInternal(true, 500);
        fail("must have thrown exception, since filter limit is set lower than blob size");
      } catch (InvalidClassException e) {
        assertTrue(e.getMessage().contains("REJECTED"));
      }
    }
  }

  private void blobDeserializationFilterInternal(boolean addFilter, int filterSize)
      throws Exception {
    Assume.assumeTrue(System.getProperty("java.version").startsWith("9."));
    byte[] bb = new byte[1000];
    for (int i = 0; i < 1000; i++) {
      bb[i] = (byte) i;
    }
    MariaDbBlob blob = new MariaDbBlob(bb, 50, 750);

    ByteArrayOutputStream bos = new ByteArrayOutputStream();
    ObjectOutputStream oos = new ObjectOutputStream(bos);
    oos.writeObject(blob);
    oos.flush();
    oos.close();
    bos.close();

    byte[] data = bos.toByteArray();

    ByteArrayInputStream bis = new ByteArrayInputStream(data);
    ObjectInputStream ois = new ObjectInputStream(bis);

    if (addFilter) {
      // equivalent of :  (but permit compilation if java < 9)
      // ois.setObjectInputFilter(new ObjectInputFilter() {
      //  @Override
      //  public Status checkInput(FilterInfo filterInfo) {
      //      if (filterInfo.arrayLength() > 500) return Status.REJECTED;
      //      return Status.ALLOWED;
      //  }
      // });

      ClassLoader cl = BlobTest.class.getClassLoader();
      Class<?> objectInputFilterClass = Class.forName("java.io.ObjectInputFilter");

      Object objectInputFilterImpl =
          Proxy.newProxyInstance(
              cl,
              new Class[] {objectInputFilterClass},
              (proxy, method, args) -> {
                Class<?> filterInfoClass = Class.forName("java.io.ObjectInputFilter$FilterInfo");
                Method arrayLengthMethod = filterInfoClass.getDeclaredMethod("arrayLength");
                Long arrayLength = (Long) arrayLengthMethod.invoke(args[0]);
                Class<?> statusClass = Class.forName("java.io.ObjectInputFilter$Status");
                Field rejected = statusClass.getField("REJECTED");
                Field allowed = statusClass.getField("ALLOWED");
                if (arrayLength > filterSize) {
                  return rejected.get(null);
                }
                return allowed.get(null);
              });

      Method setObjectInputFilterMethod =
          ObjectInputStream.class.getDeclaredMethod("setObjectInputFilter", objectInputFilterClass);
      setObjectInputFilterMethod.invoke(ois, objectInputFilterImpl);
    }

    MariaDbBlob resultBlob = (MariaDbBlob) ois.readObject();
    assertEquals(750, resultBlob.data.length);
    assertEquals(0, resultBlob.offset);
    assertEquals(750, resultBlob.length);

    byte[] blobBytes = resultBlob.getBytes(1, 1000);
    for (int i = 0; i < 750; i++) {
      assertEquals(bb[i + 50], blobBytes[i]);
    }
  }

  @Test
  public void connectionBlob() throws SQLException {
    Blob blob = sharedConnection.createBlob();
    assertArrayEquals(new byte[] {0}, blob.getBytes(1, 1));
    blob.setBytes(5, new byte[] {1, 2, 3, 4, 5, 6});
    assertArrayEquals(new byte[] {0, 0, 0, 0, 1, 2, 3, 4, 5}, blob.getBytes(1, 9));
  }
}