69 super.writeEndDatabase(); |
69 super.writeEndDatabase(); |
70 printEndElement(); |
70 printEndElement(); |
71 } |
71 } |
72 |
72 |
73 @Override |
73 @Override |
74 public void writeStartResultSet() { |
74 public void writeStartStatement() { |
75 super.writeStartResultSet(); |
75 super.writeStartStatement(); |
76 printStartElement(qname("resultSet")); |
76 printStartElement(qname("statement")); |
77 } |
77 } |
78 |
78 |
79 @Override |
79 @Override |
80 public void writeEndResultSet() { |
80 public void writeEndStatement() { |
81 super.writeEndResultSet(); |
81 super.writeEndStatement(); |
82 printEndElement(); |
82 printEndElement(); |
83 } |
83 } |
84 |
84 |
85 @Override |
85 @Override |
86 public void writeQuery(String sql) { |
86 public void writeQuery(String sql) { |
104 } |
104 } |
105 |
105 |
106 } |
106 } |
107 |
107 |
108 @Override |
108 @Override |
109 public void writeColumnsHeader(ColumnsHeader header) { |
109 public void writeStartResultSet(ColumnsHeader header) { |
110 super.writeColumnsHeader(header); |
110 super.writeStartResultSet(header); |
|
111 printStartElement(qname("resultSet")); |
111 |
112 |
112 for (ColumnDescriptor cd : header.getColumnDescriptors()) { |
113 for (ColumnDescriptor cd : header.getColumnDescriptors()) { |
113 Map<QName, String> attributes = new LinkedHashMap<>(4); |
114 Map<QName, String> attributes = new LinkedHashMap<>(4); |
114 attributes.put(qname("label"), cd.getLabel()); |
115 attributes.put(qname("label"), cd.getLabel()); |
115 attributes.put(qname("name"), cd.getName()); |
116 attributes.put(qname("name"), cd.getName()); |
116 attributes.put(qname("typeName"), cd.getTypeName()); |
117 attributes.put(qname("typeName"), cd.getTypeName()); |
117 attributes.put(qname("type"), String.valueOf(cd.getType())); |
118 attributes.put(qname("type"), String.valueOf(cd.getType())); |
118 printEmptyElement(qname("columnHeader"), attributes); |
119 printEmptyElement(qname("columnHeader"), attributes); |
119 } |
120 } |
|
121 } |
|
122 |
|
123 @Override |
|
124 public void writeEndResultSet() { |
|
125 super.writeEndResultSet(); |
|
126 printEndElement(); |
120 } |
127 } |
121 |
128 |
122 @Override |
129 @Override |
123 public void writeStartRow() { |
130 public void writeStartRow() { |
124 super.writeStartRow(); |
131 super.writeStartRow(); |
143 super.writeEndRow(); |
150 super.writeEndRow(); |
144 printEndElement(); |
151 printEndElement(); |
145 } |
152 } |
146 |
153 |
147 @Override |
154 @Override |
148 public void writeStartUpdatesResult() { |
155 public void writeUpdatesResult(int updatedRowsCount) { |
149 super.writeStartUpdatesResult(); |
156 super.writeUpdatesResult(updatedRowsCount); |
150 printStartElement(qname("updatesResult")); |
|
151 } |
|
152 |
|
153 @Override |
|
154 public void writeUpdatedRowsCount(int updatedRowsCount) { |
|
155 super.writeUpdatedRowsCount(updatedRowsCount); |
|
156 printTextElement(qname("updatedRows"), null, String.valueOf(updatedRowsCount)); |
157 printTextElement(qname("updatedRows"), null, String.valueOf(updatedRowsCount)); |
157 } |
|
158 |
|
159 @Override |
|
160 public void writeEndUpdatesResult() { |
|
161 super.writeEndUpdatesResult(); |
|
162 printEndElement(); |
|
163 } |
158 } |
164 |
159 |
165 protected String toString(Object value) { |
160 protected String toString(Object value) { |
166 return String.valueOf(value); |
161 return String.valueOf(value); |
167 } |
162 } |