Skip to content

Commit

Permalink
#832 change update sequence process
Browse files Browse the repository at this point in the history
  • Loading branch information
koda-masaru committed Sep 13, 2017
1 parent b89ba87 commit b757853
Show file tree
Hide file tree
Showing 17 changed files with 119 additions and 34 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -187,8 +187,13 @@ public AccountImagesEntity rawPhysicalInsert(AccountImagesEntity entity) {
entity.getDeleteFlag());
String driverClass = ConnectionManager.getInstance().getDriverClass(getConnectionName());
if (ORMappingParameter.DRIVER_NAME_POSTGRESQL.equals(driverClass)) {
String setValSql = "select setval('ACCOUNT_IMAGES_IMAGE_ID_seq', (select max(IMAGE_ID) from ACCOUNT_IMAGES));";
executeQuerySingle(setValSql, Long.class);
String maxSql = "SELECT MAX(IMAGE_ID) from ACCOUNT_IMAGES;";
long max = executeQuerySingle(maxSql, Long.class);
if (max < 1) {
max = 1;
}
String setValSql = "SELECT SETVAL('ACCOUNT_IMAGES_IMAGE_ID_seq', ?);";
executeQuerySingle(setValSql, Long.class, max);
}
return entity;
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -183,8 +183,13 @@ public ActivitiesEntity rawPhysicalInsert(ActivitiesEntity entity) {
entity.getDeleteFlag());
String driverClass = ConnectionManager.getInstance().getDriverClass(getConnectionName());
if (ORMappingParameter.DRIVER_NAME_POSTGRESQL.equals(driverClass)) {
String setValSql = "select setval('ACTIVITIES_ACTIVITY_NO_seq', (select max(ACTIVITY_NO) from ACTIVITIES));";
executeQuerySingle(setValSql, Long.class);
String maxSql = "SELECT MAX(ACTIVITY_NO) from ACTIVITIES;";
long max = executeQuerySingle(maxSql, Long.class);
if (max < 1) {
max = 1;
}
String setValSql = "SELECT SETVAL('ACTIVITIES_ACTIVITY_NO_seq', ?);";
executeQuerySingle(setValSql, Long.class, max);
}
return entity;
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -185,8 +185,13 @@ public BadgesEntity rawPhysicalInsert(BadgesEntity entity) {
entity.getDeleteFlag());
String driverClass = ConnectionManager.getInstance().getDriverClass(getConnectionName());
if (ORMappingParameter.DRIVER_NAME_POSTGRESQL.equals(driverClass)) {
String setValSql = "select setval('BADGES_NO_seq', (select max(NO) from BADGES));";
executeQuerySingle(setValSql, Long.class);
String maxSql = "SELECT MAX(NO) from BADGES;";
long max = executeQuerySingle(maxSql, Long.class);
if (max < 1) {
max = 1;
}
String setValSql = "SELECT SETVAL('BADGES_NO_seq', ?);";
executeQuerySingle(setValSql, Long.class, max);
}
return entity;
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -183,8 +183,13 @@ public CommentsEntity rawPhysicalInsert(CommentsEntity entity) {
entity.getDeleteFlag());
String driverClass = ConnectionManager.getInstance().getDriverClass(getConnectionName());
if (ORMappingParameter.DRIVER_NAME_POSTGRESQL.equals(driverClass)) {
String setValSql = "select setval('COMMENTS_COMMENT_NO_seq', (select max(COMMENT_NO) from COMMENTS));";
executeQuerySingle(setValSql, Long.class);
String maxSql = "SELECT MAX(COMMENT_NO) from COMMENTS;";
long max = executeQuerySingle(maxSql, Long.class);
if (max < 1) {
max = 1;
}
String setValSql = "SELECT SETVAL('COMMENTS_COMMENT_NO_seq', ?);";
executeQuerySingle(setValSql, Long.class, max);
}
return entity;
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -188,8 +188,13 @@ public DraftKnowledgesEntity rawPhysicalInsert(DraftKnowledgesEntity entity) {
entity.getDeleteFlag());
String driverClass = ConnectionManager.getInstance().getDriverClass(getConnectionName());
if (ORMappingParameter.DRIVER_NAME_POSTGRESQL.equals(driverClass)) {
String setValSql = "select setval('DRAFT_KNOWLEDGES_DRAFT_ID_seq', (select max(DRAFT_ID) from DRAFT_KNOWLEDGES));";
executeQuerySingle(setValSql, Long.class);
String maxSql = "SELECT MAX(DRAFT_ID) from DRAFT_KNOWLEDGES;";
long max = executeQuerySingle(maxSql, Long.class);
if (max < 1) {
max = 1;
}
String setValSql = "SELECT SETVAL('DRAFT_KNOWLEDGES_DRAFT_ID_seq', ?);";
executeQuerySingle(setValSql, Long.class, max);
}
return entity;
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -188,8 +188,13 @@ public KnowledgeFilesEntity rawPhysicalInsert(KnowledgeFilesEntity entity) {
entity.getDeleteFlag());
String driverClass = ConnectionManager.getInstance().getDriverClass(getConnectionName());
if (ORMappingParameter.DRIVER_NAME_POSTGRESQL.equals(driverClass)) {
String setValSql = "select setval('KNOWLEDGE_FILES_FILE_NO_seq', (select max(FILE_NO) from KNOWLEDGE_FILES));";
executeQuerySingle(setValSql, Long.class);
String maxSql = "SELECT MAX(FILE_NO) from KNOWLEDGE_FILES;";
long max = executeQuerySingle(maxSql, Long.class);
if (max < 1) {
max = 1;
}
String setValSql = "SELECT SETVAL('KNOWLEDGE_FILES_FILE_NO_seq', ?);";
executeQuerySingle(setValSql, Long.class, max);
}
return entity;
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -191,8 +191,13 @@ public KnowledgesEntity rawPhysicalInsert(KnowledgesEntity entity) {
entity.getDeleteFlag());
String driverClass = ConnectionManager.getInstance().getDriverClass(getConnectionName());
if (ORMappingParameter.DRIVER_NAME_POSTGRESQL.equals(driverClass)) {
String setValSql = "select setval('KNOWLEDGES_KNOWLEDGE_ID_seq', (select max(KNOWLEDGE_ID) from KNOWLEDGES));";
executeQuerySingle(setValSql, Long.class);
String maxSql = "SELECT MAX(KNOWLEDGE_ID) from KNOWLEDGES;";
long max = executeQuerySingle(maxSql, Long.class);
if (max < 1) {
max = 1;
}
String setValSql = "SELECT SETVAL('KNOWLEDGES_KNOWLEDGE_ID_seq', ?);";
executeQuerySingle(setValSql, Long.class, max);
}
return entity;
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -182,8 +182,13 @@ public LikeCommentsEntity rawPhysicalInsert(LikeCommentsEntity entity) {
entity.getDeleteFlag());
String driverClass = ConnectionManager.getInstance().getDriverClass(getConnectionName());
if (ORMappingParameter.DRIVER_NAME_POSTGRESQL.equals(driverClass)) {
String setValSql = "select setval('LIKE_COMMENTS_NO_seq', (select max(NO) from LIKE_COMMENTS));";
executeQuerySingle(setValSql, Long.class);
String maxSql = "SELECT MAX(NO) from LIKE_COMMENTS;";
long max = executeQuerySingle(maxSql, Long.class);
if (max < 1) {
max = 1;
}
String setValSql = "SELECT SETVAL('LIKE_COMMENTS_NO_seq', ?);";
executeQuerySingle(setValSql, Long.class, max);
}
return entity;
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -182,8 +182,13 @@ public LikesEntity rawPhysicalInsert(LikesEntity entity) {
entity.getDeleteFlag());
String driverClass = ConnectionManager.getInstance().getDriverClass(getConnectionName());
if (ORMappingParameter.DRIVER_NAME_POSTGRESQL.equals(driverClass)) {
String setValSql = "select setval('LIKES_NO_seq', (select max(NO) from LIKES));";
executeQuerySingle(setValSql, Long.class);
String maxSql = "SELECT MAX(NO) from LIKES;";
long max = executeQuerySingle(maxSql, Long.class);
if (max < 1) {
max = 1;
}
String setValSql = "SELECT SETVAL('LIKES_NO_seq', ?);";
executeQuerySingle(setValSql, Long.class, max);
}
return entity;
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -187,8 +187,13 @@ public MailHooksEntity rawPhysicalInsert(MailHooksEntity entity) {
entity.getDeleteFlag());
String driverClass = ConnectionManager.getInstance().getDriverClass(getConnectionName());
if (ORMappingParameter.DRIVER_NAME_POSTGRESQL.equals(driverClass)) {
String setValSql = "select setval('MAIL_HOOKS_HOOK_ID_seq', (select max(HOOK_ID) from MAIL_HOOKS));";
executeQuerySingle(setValSql, Long.class);
String maxSql = "SELECT MAX(HOOK_ID) from MAIL_HOOKS;";
long max = executeQuerySingle(maxSql, Long.class);
if (max < 1) {
max = 1;
}
String setValSql = "SELECT SETVAL('MAIL_HOOKS_HOOK_ID_seq', ?);";
executeQuerySingle(setValSql, Long.class, max);
}
return entity;
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -182,8 +182,13 @@ public PinsEntity rawPhysicalInsert(PinsEntity entity) {
entity.getDeleteFlag());
String driverClass = ConnectionManager.getInstance().getDriverClass(getConnectionName());
if (ORMappingParameter.DRIVER_NAME_POSTGRESQL.equals(driverClass)) {
String setValSql = "select setval('PINS_NO_seq', (select max(NO) from PINS));";
executeQuerySingle(setValSql, Long.class);
String maxSql = "SELECT MAX(NO) from PINS;";
long max = executeQuerySingle(maxSql, Long.class);
if (max < 1) {
max = 1;
}
String setValSql = "SELECT SETVAL('PINS_NO_seq', ?);";
executeQuerySingle(setValSql, Long.class, max);
}
return entity;
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -183,8 +183,13 @@ public StocksEntity rawPhysicalInsert(StocksEntity entity) {
entity.getDeleteFlag());
String driverClass = ConnectionManager.getInstance().getDriverClass(getConnectionName());
if (ORMappingParameter.DRIVER_NAME_POSTGRESQL.equals(driverClass)) {
String setValSql = "select setval('STOCKS_STOCK_ID_seq', (select max(STOCK_ID) from STOCKS));";
executeQuerySingle(setValSql, Long.class);
String maxSql = "SELECT MAX(STOCK_ID) from STOCKS;";
long max = executeQuerySingle(maxSql, Long.class);
if (max < 1) {
max = 1;
}
String setValSql = "SELECT SETVAL('STOCKS_STOCK_ID_seq', ?);";
executeQuerySingle(setValSql, Long.class, max);
}
return entity;
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -181,8 +181,13 @@ public TagsEntity rawPhysicalInsert(TagsEntity entity) {
entity.getDeleteFlag());
String driverClass = ConnectionManager.getInstance().getDriverClass(getConnectionName());
if (ORMappingParameter.DRIVER_NAME_POSTGRESQL.equals(driverClass)) {
String setValSql = "select setval('TAGS_TAG_ID_seq', (select max(TAG_ID) from TAGS));";
executeQuerySingle(setValSql, Long.class);
String maxSql = "SELECT MAX(TAG_ID) from TAGS;";
long max = executeQuerySingle(maxSql, Long.class);
if (max < 1) {
max = 1;
}
String setValSql = "SELECT SETVAL('TAGS_TAG_ID_seq', ?);";
executeQuerySingle(setValSql, Long.class, max);
}
return entity;
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -183,8 +183,13 @@ public TemplateMastersEntity rawPhysicalInsert(TemplateMastersEntity entity) {
entity.getDeleteFlag());
String driverClass = ConnectionManager.getInstance().getDriverClass(getConnectionName());
if (ORMappingParameter.DRIVER_NAME_POSTGRESQL.equals(driverClass)) {
String setValSql = "select setval('TEMPLATE_MASTERS_TYPE_ID_seq', (select max(TYPE_ID) from TEMPLATE_MASTERS));";
executeQuerySingle(setValSql, Long.class);
String maxSql = "SELECT MAX(TYPE_ID) from TEMPLATE_MASTERS;";
long max = executeQuerySingle(maxSql, Long.class);
if (max < 1) {
max = 1;
}
String setValSql = "SELECT SETVAL('TEMPLATE_MASTERS_TYPE_ID_seq', ?);";
executeQuerySingle(setValSql, Long.class, max);
}
return entity;
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -182,8 +182,13 @@ public ViewHistoriesEntity rawPhysicalInsert(ViewHistoriesEntity entity) {
entity.getDeleteFlag());
String driverClass = ConnectionManager.getInstance().getDriverClass(getConnectionName());
if (ORMappingParameter.DRIVER_NAME_POSTGRESQL.equals(driverClass)) {
String setValSql = "select setval('VIEW_HISTORIES_HISTORY_NO_seq', (select max(HISTORY_NO) from VIEW_HISTORIES));";
executeQuerySingle(setValSql, Long.class);
String maxSql = "SELECT MAX(HISTORY_NO) from VIEW_HISTORIES;";
long max = executeQuerySingle(maxSql, Long.class);
if (max < 1) {
max = 1;
}
String setValSql = "SELECT SETVAL('VIEW_HISTORIES_HISTORY_NO_seq', ?);";
executeQuerySingle(setValSql, Long.class, max);
}
return entity;
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -182,8 +182,13 @@ public VotesEntity rawPhysicalInsert(VotesEntity entity) {
entity.getDeleteFlag());
String driverClass = ConnectionManager.getInstance().getDriverClass(getConnectionName());
if (ORMappingParameter.DRIVER_NAME_POSTGRESQL.equals(driverClass)) {
String setValSql = "select setval('VOTES_VOTE_NO_seq', (select max(VOTE_NO) from VOTES));";
executeQuerySingle(setValSql, Long.class);
String maxSql = "SELECT MAX(VOTE_NO) from VOTES;";
long max = executeQuerySingle(maxSql, Long.class);
if (max < 1) {
max = 1;
}
String setValSql = "SELECT SETVAL('VOTES_VOTE_NO_seq', ?);";
executeQuerySingle(setValSql, Long.class, max);
}
return entity;
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -182,8 +182,13 @@ public WebhookConfigsEntity rawPhysicalInsert(WebhookConfigsEntity entity) {
entity.getDeleteFlag());
String driverClass = ConnectionManager.getInstance().getDriverClass(getConnectionName());
if (ORMappingParameter.DRIVER_NAME_POSTGRESQL.equals(driverClass)) {
String setValSql = "select setval('WEBHOOK_CONFIGS_HOOK_ID_seq', (select max(HOOK_ID) from WEBHOOK_CONFIGS));";
executeQuerySingle(setValSql, Long.class);
String maxSql = "SELECT MAX(HOOK_ID) from WEBHOOK_CONFIGS;";
long max = executeQuerySingle(maxSql, Long.class);
if (max < 1) {
max = 1;
}
String setValSql = "SELECT SETVAL('WEBHOOK_CONFIGS_HOOK_ID_seq', ?);";
executeQuerySingle(setValSql, Long.class, max);
}
return entity;
}
Expand Down

0 comments on commit b757853

Please sign in to comment.