|
|
@@ -0,0 +1,80 @@
|
|
|
+/**
|
|
|
+ * Copyright (c) 2011-2017, James Zhan 詹波 (jfinal@126.com).
|
|
|
+ *
|
|
|
+ * Licensed under the Apache License, Version 2.0 (the "License");
|
|
|
+ * you may not use this file except in compliance with the License.
|
|
|
+ * You may obtain a copy of the License at
|
|
|
+ *
|
|
|
+ * http://www.apache.org/licenses/LICENSE-2.0
|
|
|
+ *
|
|
|
+ * Unless required by applicable law or agreed to in writing, software
|
|
|
+ * distributed under the License is distributed on an "AS IS" BASIS,
|
|
|
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
|
+ * See the License for the specific language governing permissions and
|
|
|
+ * limitations under the License.
|
|
|
+ */
|
|
|
+
|
|
|
+package com.jfinal.plugin.activerecord.builder;
|
|
|
+
|
|
|
+import java.sql.ResultSet;
|
|
|
+import java.sql.ResultSetMetaData;
|
|
|
+import java.sql.SQLException;
|
|
|
+import java.sql.Types;
|
|
|
+import java.util.ArrayList;
|
|
|
+import java.util.List;
|
|
|
+import java.util.Map;
|
|
|
+import com.jfinal.plugin.activerecord.CPI;
|
|
|
+import com.jfinal.plugin.activerecord.Config;
|
|
|
+import com.jfinal.plugin.activerecord.ModelBuilder;
|
|
|
+import com.jfinal.plugin.activerecord.Record;
|
|
|
+import com.jfinal.plugin.activerecord.RecordBuilder;
|
|
|
+
|
|
|
+/**
|
|
|
+ * TimestampProcessedRecordBuilder
|
|
|
+ * 时间戳被处理过的 RecordBuilder
|
|
|
+ * oracle 从 Connection 中取值时需要调用具体的 getTimestamp(int) 来取值
|
|
|
+ */
|
|
|
+public class TimestampProcessedRecordBuilder extends RecordBuilder {
|
|
|
+
|
|
|
+ public static final TimestampProcessedRecordBuilder me = new TimestampProcessedRecordBuilder();
|
|
|
+
|
|
|
+ @SuppressWarnings("unchecked")
|
|
|
+ public List<Record> build(Config config, ResultSet rs) throws SQLException {
|
|
|
+ List<Record> result = new ArrayList<Record>();
|
|
|
+ ResultSetMetaData rsmd = rs.getMetaData();
|
|
|
+ int columnCount = rsmd.getColumnCount();
|
|
|
+ String[] labelNames = new String[columnCount + 1];
|
|
|
+ int[] types = new int[columnCount + 1];
|
|
|
+ buildLabelNamesAndTypes(rsmd, labelNames, types);
|
|
|
+ while (rs.next()) {
|
|
|
+ Record record = new Record();
|
|
|
+ CPI.setColumnsMap(record, config.getContainerFactory().getColumnsMap());
|
|
|
+ Map<String, Object> columns = record.getColumns();
|
|
|
+ for (int i=1; i<=columnCount; i++) {
|
|
|
+ Object value;
|
|
|
+ if (types[i] < Types.DATE)
|
|
|
+ value = rs.getObject(i);
|
|
|
+ else if (types[i] == Types.TIMESTAMP)
|
|
|
+ value = rs.getTimestamp(i);
|
|
|
+ else if (types[i] == Types.DATE)
|
|
|
+ value = rs.getDate(i);
|
|
|
+ else if (types[i] == Types.CLOB)
|
|
|
+ value = ModelBuilder.me.handleClob(rs.getClob(i));
|
|
|
+ else if (types[i] == Types.NCLOB)
|
|
|
+ value = ModelBuilder.me.handleClob(rs.getNClob(i));
|
|
|
+ else if (types[i] == Types.BLOB)
|
|
|
+ value = ModelBuilder.me.handleBlob(rs.getBlob(i));
|
|
|
+ else
|
|
|
+ value = rs.getObject(i);
|
|
|
+
|
|
|
+ columns.put(labelNames[i], value);
|
|
|
+ }
|
|
|
+ result.add(record);
|
|
|
+ }
|
|
|
+ return result;
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|