@@ -166,11 +166,12 @@ public class DbPro {
}
public String queryStr(String sql, Object... paras) {
- return (String)queryColumn(sql, paras);
+ Object s = queryColumn(sql, paras);
+ return s != null ? s.toString() : null;
public String queryStr(String sql) {
- return (String)queryColumn(sql, NULL_PARA_ARRAY);
+ return queryStr(sql, NULL_PARA_ARRAY);
public Integer queryInt(String sql, Object... paras) {
@@ -195,7 +195,9 @@ public abstract class Model<M extends Model> implements Serializable {
* Get attribute of mysql type: varchar, char, enum, set, text, tinytext, mediumtext, longtext
*/
public String getStr(String attr) {
- return (String)attrs.get(attr);
+ // return (String)attrs.get(attr);
+ Object s = attrs.get(attr);
/**
@@ -208,7 +208,9 @@ public class Record implements Serializable {
* Get column of mysql type: varchar, char, enum, set, text, tinytext, mediumtext, longtext
public String getStr(String column) {
- return (String)getColumns().get(column);
+ // return (String)getColumns().get(column);
+ Object s = getColumns().get(column);
@@ -222,12 +222,14 @@ public class PostgreSqlDialect extends Dialect {
if (model.get(pKey) == null || isOracle()) {
if (rs.next()) {
Class<?> colType = table.getColumnType(pKey);
- if (colType == Integer.class || colType == int.class) {
- model.set(pKey, rs.getInt(pKey));
- } else if (colType == Long.class || colType == long.class) {
- model.set(pKey, rs.getLong(pKey));
- } else {
- model.set(pKey, rs.getObject(pKey));
+ if (colType != null) {
+ if (colType == Integer.class || colType == int.class) {
+ model.set(pKey, rs.getInt(pKey));
+ } else if (colType == Long.class || colType == long.class) {
+ model.set(pKey, rs.getLong(pKey));
+ } else {
+ model.set(pKey, rs.getObject(pKey));
+ }