Fix getElement* methods.
This commit is contained in:
parent
db926b2afb
commit
9fca939109
1 changed files with 15 additions and 3 deletions
|
@ -1226,7 +1226,7 @@ public class SQLSikevaDB implements SikevaDB {
|
||||||
connection = getConnection();
|
connection = getConnection();
|
||||||
connection.setAutoCommit(true);
|
connection.setAutoCommit(true);
|
||||||
statement = connection
|
statement = connection
|
||||||
.prepareStatement("SELECT ID,TOPKEY,SUBKEY,VALUE,SIZE,DIGEST,CREATION_DATE,EDITION_DATE,ARCHIVE_DATE FROM sikevadb_elements WHERE ARCHIVE_DATE IS NOT NULL AND TOPKEY=? ORDER BY CREATION_DATE ASC");
|
.prepareStatement("SELECT ID,TOPKEY,SUBKEY,VALUE,SIZE,DIGEST,CREATION_DATE,EDITION_DATE,ARCHIVE_DATE FROM sikevadb_elements WHERE ARCHIVE_DATE IS NULL AND TOPKEY=? ORDER BY CREATION_DATE ASC");
|
||||||
statement.setString(1, key);
|
statement.setString(1, key);
|
||||||
resultSet = statement.executeQuery();
|
resultSet = statement.executeQuery();
|
||||||
|
|
||||||
|
@ -1278,7 +1278,7 @@ public class SQLSikevaDB implements SikevaDB {
|
||||||
connection = getConnection();
|
connection = getConnection();
|
||||||
connection.setAutoCommit(true);
|
connection.setAutoCommit(true);
|
||||||
statement = connection
|
statement = connection
|
||||||
.prepareStatement("SELECT ID,TOPKEY,SUBKEY,VALUE,SIZE,DIGEST,CREATION_DATE,EDITION_DATE,ARCHIVE_DATE FROM sikevadb_elements WHERE ARCHIVE_DATE IS NOT NULL AND TOPKEY=? AND SUBKEY=? ORDER BY CREATION_DATE ASC");
|
.prepareStatement("SELECT ID,TOPKEY,SUBKEY,VALUE,SIZE,DIGEST,CREATION_DATE,EDITION_DATE,ARCHIVE_DATE FROM sikevadb_elements WHERE ARCHIVE_DATE IS NULL AND TOPKEY=? AND SUBKEY=? ORDER BY CREATION_DATE ASC");
|
||||||
statement.setString(1, key);
|
statement.setString(1, key);
|
||||||
statement.setString(2, subkey);
|
statement.setString(2, subkey);
|
||||||
resultSet = statement.executeQuery();
|
resultSet = statement.executeQuery();
|
||||||
|
@ -2089,6 +2089,8 @@ public class SQLSikevaDB implements SikevaDB {
|
||||||
@Override
|
@Override
|
||||||
public void renameKey(final String oldKey, final String newKey) throws SQLException {
|
public void renameKey(final String oldKey, final String newKey) throws SQLException {
|
||||||
|
|
||||||
|
logger.info("renameKey starting... [{}][{}]", oldKey, newKey);
|
||||||
|
|
||||||
//
|
//
|
||||||
Connection connection = null;
|
Connection connection = null;
|
||||||
PreparedStatement statement = null;
|
PreparedStatement statement = null;
|
||||||
|
@ -2107,6 +2109,8 @@ public class SQLSikevaDB implements SikevaDB {
|
||||||
} finally {
|
} finally {
|
||||||
close(connection, statement, resultSet);
|
close(connection, statement, resultSet);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
logger.info("renameKey done.");
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
@ -2115,6 +2119,8 @@ public class SQLSikevaDB implements SikevaDB {
|
||||||
@Override
|
@Override
|
||||||
public void replaceInValue(final String key, final String... tokens) throws SQLException {
|
public void replaceInValue(final String key, final String... tokens) throws SQLException {
|
||||||
|
|
||||||
|
logger.info("replaceInValue starting... [{}]", key);
|
||||||
|
|
||||||
//
|
//
|
||||||
String value = getValue(key);
|
String value = getValue(key);
|
||||||
|
|
||||||
|
@ -2125,6 +2131,8 @@ public class SQLSikevaDB implements SikevaDB {
|
||||||
|
|
||||||
//
|
//
|
||||||
put(key, value);
|
put(key, value);
|
||||||
|
|
||||||
|
logger.info("replaceInValue done.");
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
@ -2133,13 +2141,15 @@ public class SQLSikevaDB implements SikevaDB {
|
||||||
@Override
|
@Override
|
||||||
public void replaceInValues(final String key, final String... tokens) throws SQLException {
|
public void replaceInValues(final String key, final String... tokens) throws SQLException {
|
||||||
|
|
||||||
|
logger.info("replaceInValues starting... [{}]", key);
|
||||||
|
|
||||||
//
|
//
|
||||||
Elements elements = getElements(key);
|
Elements elements = getElements(key);
|
||||||
|
|
||||||
long count = 0;
|
long count = 0;
|
||||||
for (Element element : elements) {
|
for (Element element : elements) {
|
||||||
//
|
//
|
||||||
System.out.println(element.getKey() + count + " " + element.getSubkey() + "/" + elements.size());
|
logger.info(element.getKey() + count + " " + element.getSubkey() + "/" + elements.size());
|
||||||
|
|
||||||
if (element.getSubkey() != null) {
|
if (element.getSubkey() != null) {
|
||||||
//
|
//
|
||||||
|
@ -2157,6 +2167,8 @@ public class SQLSikevaDB implements SikevaDB {
|
||||||
put(element.getKey(), element.getSubkey(), value);
|
put(element.getKey(), element.getSubkey(), value);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
logger.info("replaceInValues done.");
|
||||||
}
|
}
|
||||||
|
|
||||||
public void setDriverClassname(final String driverClassname) {
|
public void setDriverClassname(final String driverClassname) {
|
||||||
|
|
Loading…
Reference in a new issue