1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22 package org.dbunit.dataset.datatype;
23
24 import java.math.BigDecimal;
25 import java.sql.PreparedStatement;
26 import java.sql.ResultSet;
27 import java.sql.SQLException;
28
29 import org.dbunit.dataset.ITable;
30 import org.slf4j.Logger;
31 import org.slf4j.LoggerFactory;
32
33
34
35
36
37 public class IntegerDataType extends AbstractDataType
38 {
39 private static final Logger logger =
40 LoggerFactory.getLogger(IntegerDataType.class);
41
42 IntegerDataType(final String name, final int sqlType)
43 {
44 super(name, sqlType, Integer.class, true);
45 }
46
47
48
49
50 @Override
51 public Object typeCast(final Object value) throws TypeCastException
52 {
53 logger.debug("typeCast(value={}) - start", value);
54
55 if (value == null || value == ITable.NO_VALUE)
56 {
57 return null;
58 }
59
60 if (value instanceof Number)
61 {
62 return ((Number) value).intValue();
63 }
64
65
66 if (value instanceof String)
67 {
68 final String string = (String) value;
69
70 if ("false".equalsIgnoreCase(string))
71 {
72 return 0;
73 }
74
75 if ("true".equalsIgnoreCase(string))
76 {
77 return 1;
78 }
79 }
80
81
82 final String stringValue = value.toString().trim();
83 if (stringValue.length() <= 0)
84 {
85 return null;
86 }
87
88 try
89 {
90 return typeCast(new BigDecimal(stringValue));
91 } catch (final java.lang.NumberFormatException e)
92 {
93 throw new TypeCastException(value, this, e);
94 }
95 }
96
97 @Override
98 public Object getSqlValue(final int column, final ResultSet resultSet)
99 throws SQLException, TypeCastException
100 {
101 logger.debug("getSqlValue(column={}, resultSet={}) - start", column,
102 resultSet);
103 final int rawValue = resultSet.getInt(column);
104 final Integer value = resultSet.wasNull() ? null : rawValue;
105 logger.debug("getSqlValue: column={}, value={}", column, value);
106 return value;
107 }
108
109 @Override
110 public void setSqlValue(final Object value, final int column,
111 final PreparedStatement statement)
112 throws SQLException, TypeCastException
113 {
114 logger.debug("setSqlValue(value={}, column={}, statement={}) - start",
115 value, column, statement);
116
117 statement.setInt(column, (Integer) typeCast(value));
118 }
119 }