{@inheritDoc}

@see jp.co.future.uroborosql.fluent.SqlFluent#blobParam(java.lang.String, java.io.InputStream)
163176
@Override
	public SqlContext blobParam(final String parameterName, final InputStream value) {
		return param(new StreamParameter(parameterName, value));
	}
714144
protected int setStreamParameter(final PreparedStatement preparedStatement, int index,
			final BindParameterMapperManager parameterMapperManager) throws SQLException {

		if (len > -1) {
			preparedStatement.setBinaryStream(index, stream, len);
		} else {
			preparedStatement.setBinaryStream(index, stream);
		}

		parameterLog(index);
		index++;

		return index;
	}
458937
private String readBlobAsString(Blob logBlob) throws SQLException {
    if (logBlob == null) {
      return StringUtils.EMPTY;
    }

    byte[] ba = logBlob.getBytes(1L, (int) (logBlob.length()));

    if (ba == null) {
      return StringUtils.EMPTY;
    }
    String baString = Base64.encodeBase64String(ba);
    return baString;
  }
696092
@Override
    public void setBytes(int parameterIndex, byte[] x) throws SQLException
    {
        checkParameterBounds(parameterIndex);
        this.parameters[parameterIndex-1] = x;
    }
279940
@Override
	public void updateBlob(final String columnLabel, final Blob x) throws SQLException {
		wrapped.updateBlob(columnLabel, x);
	}
320369
private static void setBlob(PreparedStatement ps, int i, Object o, Class<?> cls)
            throws SQLException {
        final InputStream is;
        if (o instanceof byte[]) {
            is = new ByteArrayInputStream((byte[]) o);
        }
396223
@Override
	public void updateBinaryStream(final int columnIndex, final InputStream x) throws SQLException {
		wrapped.updateBinaryStream(columnIndex, x);
	}
1033627
private Parameter getBindParameter(final String paramName) {
		// メソッド呼び出しかどうかで処理を振り分け
		if (paramName.contains(".") && paramName.contains("(") && paramName.contains(")")) {
			// メソッド呼び出しの場合は、SqlParserで値を評価するタイミングでparameterをaddしているので、そのまま返却する
			return parameterMap.get(paramName);
		} else {
			String[] keys = StringUtils.split(paramName, ".");
			String baseName = keys[0];

			Parameter parameter = parameterMap.get(baseName);
			if (parameter == null) {
				return null;
			}

			if (keys.length > 1) {
				String propertyName = keys[1];
				return parameter.createSubParameter(propertyName);
			}

			return parameter;
		}
	}
1361870
@NonNull
    @Override
    public MutableArray insertBlob(int index, Blob value) {
        return insertValue(index, value);
    }
118727
@Override
    public CreateBlobResult createBlockBlob(String blob,
            InputStream contentStream) throws ServiceException {
        return blobService.createBlockBlob(containerName, blob, contentStream);
    }
663094
@Override
    public Blob convert(INDArray toConvert) throws SQLException {
        ByteBuffer byteBuffer = BinarySerde.toByteBuffer(toConvert);
        Buffer buffer = (Buffer) byteBuffer;
        buffer.rewind();
        byte[] arr = new byte[byteBuffer.capacity()];
        byteBuffer.get(arr);
        Connection c = dataSource.getConnection();
        Blob b = c.createBlob();
        b.setBytes(1, arr);
        return b;
    }
3802
protected final void setJpqlParameters(final Query query, final StreamId streamId) {
        final List<KeyValue> params = new ArrayList<>(streamId.getParameters());
        if (params.size() == 0) {
            params.add(new KeyValue("streamName", streamId.getName()));
        }
        for (int i = 0; i < params.size(); i++) {
            final KeyValue param = params.get(i);
            query.setParameter(param.getKey(), param.getValue());
        }
    }
242685
@Override
	public void updateBlob(final int columnIndex, final InputStream inputStream) throws SQLException {
		wrapped.updateBlob(columnIndex, inputStream);
	}
231062
@Override
	public SqlContext paramIfAbsent(final String parameterName, final Object value) {
		if (!hasParam(parameterName)) {
			param(parameterName, value);
		}
		return this;
	}
1278440
@Override
	public SqlContext outParam(final String parameterName, final SQLType sqlType) {
		return param(new OutParameter(parameterName, sqlType));
	}
447609
@SuppressWarnings("unchecked")
	@Override
	public T blobParamIfAbsent(final String paramName, final InputStream value) {
		context().blobParamIfAbsent(paramName, value);
		return (T) this;
	}
315711
@Override
	public SqlBatch paramStream(final Stream<?> stream) {
		if (this.stream == null) {
			this.stream = stream;
		} else {
			this.stream = Stream.concat(this.stream, stream);
		}
		return this;
	}