1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46 package org.melati.poem;
47
48 import java.sql.PreparedStatement;
49 import java.sql.ResultSet;
50 import java.sql.SQLException;
51 import java.sql.Types;
52
53 import org.apache.commons.codec.binary.Base64;
54 import org.melati.poem.dbms.Dbms;
55 import org.melati.poem.util.StringUtils;
56
57
58
59
60 public class BinaryPoemType extends SizedAtomPoemType<byte[]> {
61
62
63
64
65
66
67 public BinaryPoemType(boolean nullable, int size) {
68 super(Types.VARBINARY, "VARBINARY", nullable, size);
69 }
70
71 protected void _assertValidRaw(Object raw)
72 throws ValidationPoemException {
73 if (raw != null) {
74 if (!(raw instanceof byte[]))
75 throw new TypeMismatchPoemException(raw, this);
76 if (!sizeGreaterEqual(getSize(), ((byte[])raw).length))
77 throw new BinaryLengthValidationPoemException(this, (byte[])raw);
78 }
79 }
80
81 protected String _stringOfRaw(Object raw) {
82 return new String(Base64.encodeBase64((byte[])raw));
83 }
84
85 protected byte[] _getRaw(ResultSet rs, int col) throws SQLException {
86 return rs.getBytes(col);
87 }
88
89 protected void _setRaw(PreparedStatement ps, int col, Object string)
90 throws SQLException {
91 ps.setBytes(col, (byte[])string);
92 }
93
94 protected byte[] _rawOfString(String rawString) {
95 return Base64.decodeBase64(rawString.getBytes());
96 }
97
98 protected String _sqlDefinition(Dbms dbms) {
99 try {
100 return dbms.getBinarySqlDefinition(getSize());
101 } catch (SQLException e) {
102 throw new SQLSeriousPoemException(e);
103 }
104 }
105
106 protected boolean _canRepresent(SQLPoemType<?> other) {
107 return
108 sqlTypeCode() == other.sqlTypeCode() &&
109 other instanceof BinaryPoemType &&
110 sizeGreaterEqual(getSize(), ((BinaryPoemType)other).getSize());
111 }
112
113
114
115
116
117 public String toString() {
118 return (getNullable() ? "nullable " : "") + "binary(" + getSize() + ")";
119 }
120
121
122
123
124
125 public String toDsdType() {
126 return "byte[]";
127 }
128
129 protected void _saveColumnInfo(ColumnInfo columnInfo)
130 throws AccessPoemException {
131 columnInfo.setTypefactory(PoemTypeFactory.BINARY);
132 columnInfo.setSize(getSize());
133 }
134
135 protected String _quotedRaw(Object raw) {
136 return StringUtils.quoted(_stringOfRaw(raw), '\'');
137 }
138
139 }
140
141