View Javadoc
1   /*
2    * Copyright 2004-2025 the original author or authors.
3    *
4    * Licensed under the Apache License, Version 2.0 (the "License");
5    * you may not use this file except in compliance with the License.
6    * You may obtain a copy of the License at
7    *
8    *    https://www.apache.org/licenses/LICENSE-2.0
9    *
10   * Unless required by applicable law or agreed to in writing, software
11   * distributed under the License is distributed on an "AS IS" BASIS,
12   * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13   * See the License for the specific language governing permissions and
14   * limitations under the License.
15   */
16  package com.ibatis.sqlmap.engine.type;
17  
18  import com.ibatis.sqlmap.client.extensions.ParameterSetter;
19  import com.ibatis.sqlmap.client.extensions.ResultGetter;
20  import com.ibatis.sqlmap.client.extensions.TypeHandlerCallback;
21  
22  import java.io.ByteArrayInputStream;
23  import java.sql.Blob;
24  import java.sql.SQLException;
25  import java.sql.Types;
26  
27  /**
28   * The Class BlobTypeHandlerCallback.
29   */
30  public class BlobTypeHandlerCallback implements TypeHandlerCallback {
31  
32    @Override
33    public Object getResult(ResultGetter getter) throws SQLException {
34      Blob blob = getter.getBlob();
35      byte[] returnValue;
36      if (!getter.wasNull()) {
37        returnValue = blob.getBytes(1, (int) blob.length());
38      } else {
39        returnValue = null;
40      }
41      return returnValue;
42    }
43  
44    @Override
45    public void setParameter(ParameterSetter setter, Object parameter) throws SQLException {
46      if (null != parameter) {
47        byte[] bytes = (byte[]) parameter;
48        ByteArrayInputStream bis = new ByteArrayInputStream(bytes);
49        setter.setBinaryStream(bis, bytes.length);
50      } else {
51        setter.setNull(Types.BLOB);
52      }
53    }
54  
55    @Override
56    public Object valueOf(String s) {
57      return s;
58    }
59  
60  }