import com.mysema.query.sql.dml.SQLUpdateClause; //导入依赖的package包/类
public void modifyBalance(int i, long amount, String description) {
    if (i < 0)
        return;

    QBalance b = QBalance.balance;
    QTransactions t = QTransactions.transactions;

    try {
        SQLInsertClause balanceClause = DatabaseManager.getInstance().getInsertClause(b);
        SQLInsertClause transactionClause = DatabaseManager.getInstance().getInsertClause(t);

        transactionClause.columns(t.id, t.description, t.amount).values(i, description, amount).execute();
        balanceClause.columns(b.id, b.amount).values(i, amount).execute();
    } catch (QueryException e) {
        // Transaction insert won't fail, only balance will. when it does, update instead
        SQLUpdateClause clause = DatabaseManager.getInstance().getUpdateClause(b);

        clause.where(b.id.eq(i)).set(b.amount, b.amount.add(amount)).execute();
    }
}
 

import com.mysema.query.sql.dml.SQLUpdateClause; //导入依赖的package包/类
public void setBalance(int i, long amount, String description) {
    if (i < 0)
        return;

    QBalance b = QBalance.balance;
    QTransactions t = QTransactions.transactions;

    // We need to know the current amount to get the amount changed for the transaction log
    SQLQuery query = DatabaseManager.getInstance().getNewQuery();
    Long current = query.from(b).where(b.id.eq(i)).uniqueResult(b.amount);
    current = current == null ? 0 : current;

    try {
        SQLInsertClause balanceClause = DatabaseManager.getInstance().getInsertClause(b);
        SQLInsertClause transactionClause = DatabaseManager.getInstance().getInsertClause(t);

        transactionClause.columns(t.id, t.description, t.amount).values(i, description, amount - current).execute();
        balanceClause.columns(b.id, b.amount).values(i, amount).execute();
    } catch (QueryException e) {
        // Transaction insert won't fail, only balance will. when it does, update instead
        SQLUpdateClause clause = DatabaseManager.getInstance().getUpdateClause(b);

        clause.where(b.id.eq(i)).set(b.amount, amount).execute();
    }
}
 

import com.mysema.query.sql.dml.SQLUpdateClause; //导入依赖的package包/类
@Override
@Transactional(readOnly=false)
public void updateInitiative(InitiativeManagement initiative, Long userId, boolean basic, boolean extra) {
    Assert.notNull(initiative, "initiative");
    Assert.notNull(userId, "userId");

    Long initiativeId = initiative.getId();
    Assert.notNull(initiativeId, "initiative.id");

    SQLUpdateClause update = queryFactory.update(qInitiative);
    populateInitiative(update, initiative, userId, basic, extra);
    update.where(qInitiative.id.eq(initiative.getId()));
    
    if (update.execute() != 1) {
        throw new NotFoundException(qInitiative.getTableName(), initiative.getId());
    } 
}
 

import com.mysema.query.sql.dml.SQLUpdateClause; //导入依赖的package包/类
private void updateLink(Link link, Long initiativeId) {
    Long linkId = link.getId();
    Assert.notNull(linkId, "link.id");

    SQLUpdateClause update = queryFactory
            .update(qInitiativeLink)
            .where(
                    qInitiativeLink.id.eq(linkId),
                    qInitiativeLink.initiativeId.eq(initiativeId) // Defensive... 
                );
    populateLink(update, link);
    
    if (update.execute() != 1) {
        throw new NotFoundException(qInitiativeLink.getTableName(), linkId);
    }
}
 

import com.mysema.query.sql.dml.SQLUpdateClause; //导入依赖的package包/类
private void updateUnsentInvitation(Long initiativeId, Invitation invitation) {
    if (invitation.getSent() == null) {
        Long invitationId = invitation.getId();
        Assert.notNull(invitationId, "invitation.id");

        SQLUpdateClause update = queryFactory
                .update(qInvitation)
                .where(
                        qInvitation.id.eq(invitationId),
                        qInvitation.initiativeId.eq(initiativeId) // Defensive... 
                    );
        update.set(qInvitation.email, invitation.getEmail());
        
        if (update.execute() != 1) {
            throw new NotFoundException(qInitiativeLink.getTableName(), invitationId);
        }
    }
}
 

import com.mysema.query.sql.dml.SQLUpdateClause; //导入依赖的package包/类
@Override
@Transactional(readOnly=false)
public void updateInvitationSent(Long initiativeId, Long invitationId, String invitationCode) {
    Assert.notNull(initiativeId, "initiativeId");
    Assert.notNull(invitationId, "invitationId");
    Assert.notNull(invitationCode, "invitationCode");

    SQLUpdateClause update = queryFactory
            .update(qInvitation)
            .where(
                    qInvitation.id.eq(invitationId),
                    qInvitation.initiativeId.eq(initiativeId),  // Defensive... 
                    qInvitation.sent.isNull()
                );
    update.set(qInvitation.sent, CURRENT_TIME);
    update.set(qInvitation.invitationcode, invitationCode);
    
    if (update.execute() != 1) {
        throw new NotFoundException(qInvitation.getTableName(), invitationId);
    }
}
 

import com.mysema.query.sql.dml.SQLUpdateClause; //导入依赖的package包/类
public Long execute() {
    JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
    return jdbcTemplate.execute(new ConnectionCallback<Long>() {
        @Override
        public Long doInConnection(Connection connection) throws SQLException, DataAccessException {
            final SQLUpdateClause updateClause = new SQLUpdateClause(connection, configuration, pathBase);
            addSpec(updateClause);
            populate(updateClause);
            log(updateClause);
            return updateClause.execute();
        }
    });
}
 

import com.mysema.query.sql.dml.SQLUpdateClause; //导入依赖的package包/类
/**
 * 因为需要忽略createdTime、updatedTime，所以并没有直接使用 updateClause.populate(domain)或updateClause.populate(domain, DefaultMapper.WITH_NULL_BINDINGS)来实现set
 *
 * @param updateClause
 * @param obj
 * @param mapper
 */
public void populate(SQLUpdateClause updateClause, T obj, DefaultMapper mapper) {
    Collection<? extends Path<?>> primaryKeyColumns = pathBase.getPrimaryKey() != null
            ? pathBase.getPrimaryKey().getLocalColumns()
            : Collections.<Path<?>>emptyList();
    Map<Path<?>, Object> values = mapper.createMap(pathBase, obj);
    for (Map.Entry<Path<?>, Object> entry : values.entrySet()) {
        if (!primaryKeyColumns.contains(entry.getKey()) && !ignoreColumns.contains(entry.getKey().getMetadata().getName())) {
            updateClause.set((Path) entry.getKey(), entry.getValue());
        }
    }
}
 

import com.mysema.query.sql.dml.SQLUpdateClause; //导入依赖的package包/类
@Override
@Transactional(readOnly=false)
public void updateInitiativeState(Long initiativeId, Long userId, InitiativeState state, String comment) {
    SQLUpdateClause update = getUpdateClauseForInitiativeState(initiativeId, userId, state, comment);

    if (update.execute() != 1) {
        throw new NotFoundException(qInitiative.getTableName(), initiativeId);
    } 
}
 

import com.mysema.query.sql.dml.SQLUpdateClause; //导入依赖的package包/类
@Override
@Transactional(readOnly=false)
public void updateInitiativeStateAndAcceptanceIdentifier(Long initiativeId, Long userId, InitiativeState state, String comment, String acceptanceIdentifier) {
    SQLUpdateClause update = getUpdateClauseForInitiativeState(initiativeId, userId, state, comment)
            .set(qInitiative.acceptanceidentifier, acceptanceIdentifier);

    if (update.execute() != 1) {
        throw new NotFoundException(qInitiative.getTableName(), initiativeId);
    } 
}
 

import com.mysema.query.sql.dml.SQLUpdateClause; //导入依赖的package包/类
private SQLUpdateClause getUpdateClauseForInitiativeState(Long initiativeId, Long userId, InitiativeState state, String comment) {
    Assert.notNull(initiativeId, "initiative.id");
    return queryFactory.update(qInitiative)
            .set(qInitiative.modifierId, userId)
            .set(qInitiative.modified, CURRENT_TIME)
            .set(qInitiative.state, state)
            .set(qInitiative.statecomment, comment)
            .set(qInitiative.statedate, CURRENT_TIME) 
            .where(qInitiative.id.eq(initiativeId));
}
 

import com.mysema.query.sql.dml.SQLUpdateClause; //导入依赖的package包/类
@Override
@Transactional(readOnly = false)
public void updateSendToParliament(Long initiativeId, SendToParliamentData data) {
    SQLUpdateClause update = queryFactory.update(qInitiative)
            .set(qInitiative.parliamentidentifier, data.getParliamentIdentifier())
            .set(qInitiative.parliamentsenttime, data.getParliamentSentTime())
            .set(qInitiative.parliamenturl, data.getParliamentURL())
            .set(qInitiative.state, InitiativeState.DONE)
            .set(qInitiative.statedate, CURRENT_TIME)
            .where(qInitiative.id.eq(initiativeId));

    if (update.execute() != 1) {
        throw new NotFoundException(qInitiative.getTableName(), initiativeId);
    }
}
 

import com.mysema.query.sql.dml.SQLUpdateClause; //导入依赖的package包/类
@Override
public void endInitiative(Long initiativeId, LocalDate lastRunningDate) {
    SQLUpdateClause update = queryFactory.update(qInitiative)
            .set(qInitiative.enddate, lastRunningDate)
            .where(qInitiative.id.eq(initiativeId));

    if (update.execute() != 1) {
        throw new NotFoundException(qInitiative.getTableName(), initiativeId);
    }
}
 

import com.mysema.query.sql.dml.SQLUpdateClause; //导入依赖的package包/类
@Override
@Transactional(readOnly=false)
public void clearConfirmations(Long initiativeId, Long userId) {
    Expression<DateTime> confirmed = new CaseBuilder()
        .when(qAuthor.userId.eq(userId))
        .then(CURRENT_TIME)
        .otherwise(NULL_TIME);

    SQLUpdateClause update = queryFactory.update(qAuthor)
        .set(qAuthor.confirmed, confirmed)
        .set(qAuthor.confirmationrequestsent, NULL_TIME)
        .where(qAuthor.initiativeId.eq(initiativeId));

    update.execute();
}
 

import com.mysema.query.sql.dml.SQLUpdateClause; //导入依赖的package包/类
@Override
@Transactional(readOnly=false)
public void updateConfirmationRequestSent(Long initiativeId, Long userId) {
    SQLUpdateClause update = queryFactory.update(qAuthor)
            .set(qAuthor.confirmationrequestsent, CURRENT_TIME)
            .where(qAuthor.initiativeId.eq(initiativeId), qAuthor.userId.eq(userId));

    update.execute();
}
 

import com.mysema.query.sql.dml.SQLUpdateClause; //导入依赖的package包/类
@Override
@Transactional(readOnly=false)
public void confirmAuthor(Long initiativeId, Long userId) {
    SQLUpdateClause update = queryFactory.update(qAuthor)
            .set(qAuthor.confirmed, CURRENT_TIME)
            .where(qAuthor.initiativeId.eq(initiativeId), qAuthor.userId.eq(userId));

    if (update.execute() != 1) {
        throw new NotFoundException("author", initiativeId + ":" + userId);
    }
}
 

import com.mysema.query.sql.dml.SQLUpdateClause; //导入依赖的package包/类
@Override
@Transactional(readOnly=false)
public void updateAuthor(Long initiativeId, Long userId, Author author) {
    SQLUpdateClause update = queryFactory
            .update(qAuthor)
            .where(qAuthor.initiativeId.eq(initiativeId), qAuthor.userId.eq(userId));
    
    populateAuthor(update, author);
    
    if (update.execute() != 1) {
        throw new NotFoundException("author", initiativeId + ":" + userId);
    }
}
 

import com.mysema.query.sql.dml.SQLUpdateClause; //导入依赖的package包/类
@Override
@Transactional(readOnly=false)
public void incrementSupportCount(Long initiativeId) {
    // Increment Initiative.supportCount
    SQLUpdateClause update = queryFactory.update(qInitiative)
            .set(qInitiative.supportcount, qInitiative.supportcount.add(1))
            .where(qInitiative.id.eq(initiativeId));
    update.execute();
}
 

import com.mysema.query.sql.dml.SQLUpdateClause; //导入依赖的package包/类
@Override
@Transactional(readOnly=false)
public User loginRegisteredUser(String ssnHash) {
    User user = getRegisteredUser(ssnHash);
    if (user != null) {
        SQLUpdateClause update = queryFactory.update(qUser);
        update.set(qUser.lastlogin, new DateTime());
        update.where(qUser.id.eq(user.getId()));
        update.execute();
    }
    return user;
}
 

import com.mysema.query.sql.dml.SQLUpdateClause; //导入依赖的package包/类
@Override
public void setUserRoles(Long userId, boolean vrk, boolean om) {
    Assert.notNull(userId, "userId");
    SQLUpdateClause update = queryFactory.update(qUser);
    update.set(qUser.vrk, vrk);
    update.set(qUser.om, om);
    update.where(qUser.id.eq(userId));
    update.execute();
}