lxy/redkale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

DataJdbcSource

Browse Source
This commit is contained in:
redkale
2023-11-25 21:52:05 +08:00
parent 0a93ccb818
commit 90e813a06c
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/main/java/org/redkale/source/DataJdbcSource.java
View File

@@ -372,7 +372,7 @@ public class DataJdbcSource extends AbstractDataSqlSource {
T entity = entitys[++i];
if (primaryType == int.class || primaryType == Integer.class) {
primary.set(entity, set.getInt(1));
} else if (primaryType == long.class || primaryType == long.class) {
} else if (primaryType == long.class || primaryType == Long.class) {
primary.set(entity, set.getLong(1));
} else if (primaryType == String.class) {
primary.set(entity, set.getString(1));
@@ -398,7 +398,7 @@ public class DataJdbcSource extends AbstractDataSqlSource {
T entity = prepareInfo.entitys.get(++i);
if (primaryType == int.class || primaryType == Integer.class) {
primary.set(entity, set.getInt(1));
} else if (primaryType == long.class || primaryType == long.class) {
} else if (primaryType == long.class || primaryType == Long.class) {
primary.set(entity, set.getLong(1));
} else if (primaryType == String.class) {
primary.set(entity, set.getString(1));
@@ -548,7 +548,7 @@ public class DataJdbcSource extends AbstractDataSqlSource {
T entity = entitys[++i];
if (primaryType == int.class || primaryType == Integer.class) {
primary.set(entity, set.getInt(1));
} else if (primaryType == long.class || primaryType == long.class) {
} else if (primaryType == long.class || primaryType == Long.class) {
primary.set(entity, set.getLong(1));
} else if (primaryType == String.class) {
primary.set(entity, set.getString(1));
@@ -576,7 +576,7 @@ public class DataJdbcSource extends AbstractDataSqlSource {
T entity = prepareInfo.entitys.get(++i);
if (primaryType == int.class || primaryType == Integer.class) {
primary.set(entity, set.getInt(1));
} else if (primaryType == long.class || primaryType == long.class) {
} else if (primaryType == long.class || primaryType == Long.class) {
primary.set(entity, set.getLong(1));
} else if (primaryType == String.class) {
primary.set(entity, set.getString(1));
@@ -2143,7 +2143,7 @@ public class DataJdbcSource extends AbstractDataSqlSource {
}
prestmt = conn.prepareQueryStatement(sql);
final ResultSet set = prestmt.executeQuery();
boolean rs = set.next() ? (set.getInt(1) > 0) : false;
boolean rs = set.next() && (set.getInt(1) > 0);
set.close();
conn.offerQueryStatement(prestmt);
if (info.isLoggable(logger, Level.FINEST, sql)) {