下面列出了com.mongodb.WriteConcern#REPLICA_ACKNOWLEDGED 实例代码,或者点击链接到github查看源代码,也可以在右侧发表评论。
protected WriteConcern getWriteConcern(final ProcessContext context) {
final String writeConcernProperty = context.getProperty(WRITE_CONCERN).getValue();
WriteConcern writeConcern = null;
switch (writeConcernProperty) {
case WRITE_CONCERN_ACKNOWLEDGED:
writeConcern = WriteConcern.ACKNOWLEDGED;
break;
case WRITE_CONCERN_UNACKNOWLEDGED:
writeConcern = WriteConcern.UNACKNOWLEDGED;
break;
case WRITE_CONCERN_FSYNCED:
writeConcern = WriteConcern.FSYNCED;
break;
case WRITE_CONCERN_JOURNALED:
writeConcern = WriteConcern.JOURNALED;
break;
case WRITE_CONCERN_REPLICA_ACKNOWLEDGED:
writeConcern = WriteConcern.REPLICA_ACKNOWLEDGED;
break;
case WRITE_CONCERN_MAJORITY:
writeConcern = WriteConcern.MAJORITY;
break;
default:
writeConcern = WriteConcern.ACKNOWLEDGED;
}
return writeConcern;
}
protected WriteConcern getWriteConcern(final ProcessContext context) {
final String writeConcernProperty = context.getProperty(WRITE_CONCERN).getValue();
WriteConcern writeConcern = null;
switch (writeConcernProperty) {
case WRITE_CONCERN_ACKNOWLEDGED:
writeConcern = WriteConcern.ACKNOWLEDGED;
break;
case WRITE_CONCERN_UNACKNOWLEDGED:
writeConcern = WriteConcern.UNACKNOWLEDGED;
break;
case WRITE_CONCERN_FSYNCED:
writeConcern = WriteConcern.FSYNCED;
break;
case WRITE_CONCERN_JOURNALED:
writeConcern = WriteConcern.JOURNALED;
break;
case WRITE_CONCERN_REPLICA_ACKNOWLEDGED:
writeConcern = WriteConcern.REPLICA_ACKNOWLEDGED;
break;
case WRITE_CONCERN_MAJORITY:
writeConcern = WriteConcern.MAJORITY;
break;
default:
writeConcern = WriteConcern.ACKNOWLEDGED;
}
return writeConcern;
}
protected WriteConcern getWriteConcern(final ProcessContext context) {
final String writeConcernProperty = context.getProperty(WRITE_CONCERN).getValue();
WriteConcern writeConcern = null;
switch (writeConcernProperty) {
case WRITE_CONCERN_ACKNOWLEDGED:
writeConcern = WriteConcern.ACKNOWLEDGED;
break;
case WRITE_CONCERN_UNACKNOWLEDGED:
writeConcern = WriteConcern.UNACKNOWLEDGED;
break;
case WRITE_CONCERN_FSYNCED:
writeConcern = WriteConcern.FSYNCED;
break;
case WRITE_CONCERN_JOURNALED:
writeConcern = WriteConcern.JOURNALED;
break;
case WRITE_CONCERN_REPLICA_ACKNOWLEDGED:
writeConcern = WriteConcern.REPLICA_ACKNOWLEDGED;
break;
case WRITE_CONCERN_MAJORITY:
writeConcern = WriteConcern.MAJORITY;
break;
default:
writeConcern = WriteConcern.ACKNOWLEDGED;
}
return writeConcern;
}
@Override
public WriteConcern getWriteConcern(final ConfigurationContext context) {
final String writeConcernProperty = context.getProperty(WRITE_CONCERN).getValue();
WriteConcern writeConcern = null;
switch (writeConcernProperty) {
case WRITE_CONCERN_ACKNOWLEDGED:
writeConcern = WriteConcern.ACKNOWLEDGED;
break;
case WRITE_CONCERN_UNACKNOWLEDGED:
writeConcern = WriteConcern.UNACKNOWLEDGED;
break;
case WRITE_CONCERN_FSYNCED:
writeConcern = WriteConcern.FSYNCED;
break;
case WRITE_CONCERN_JOURNALED:
writeConcern = WriteConcern.JOURNALED;
break;
case WRITE_CONCERN_REPLICA_ACKNOWLEDGED:
writeConcern = WriteConcern.REPLICA_ACKNOWLEDGED;
break;
case WRITE_CONCERN_MAJORITY:
writeConcern = WriteConcern.MAJORITY;
break;
default:
writeConcern = WriteConcern.ACKNOWLEDGED;
}
return writeConcern;
}
@SuppressWarnings("deprecation")
private WriteConcern getWriteConcern(String writeConcern) {
if ("ACKNOWLEDGED".equalsIgnoreCase(writeConcern)) {
return WriteConcern.ACKNOWLEDGED;
}
if ("W1".equalsIgnoreCase(writeConcern)) {
return WriteConcern.W1;
}
if ("W2".equalsIgnoreCase(writeConcern)) {
return WriteConcern.W2;
}
if ("W3".equalsIgnoreCase(writeConcern)) {
return WriteConcern.W3;
}
if ("UNACKNOWLEDGED".equalsIgnoreCase(writeConcern)) {
return WriteConcern.UNACKNOWLEDGED;
}
if ("FSYNCED".equalsIgnoreCase(writeConcern)) {
return WriteConcern.FSYNCED;
}
if ("REPLICA_ACKNOWLEDGED".equalsIgnoreCase(writeConcern)) {
return WriteConcern.REPLICA_ACKNOWLEDGED;
}
if ("NORMAL".equalsIgnoreCase(writeConcern)) {
return WriteConcern.NORMAL;
}
if ("SAFE".equalsIgnoreCase(writeConcern)) {
return WriteConcern.SAFE;
}
if ("MAJORITY".equalsIgnoreCase(writeConcern)) {
return WriteConcern.MAJORITY;
}
if ("FSYNC_SAFE".equalsIgnoreCase(writeConcern)) {
return WriteConcern.FSYNC_SAFE;
}
if ("JOURNAL_SAFE".equalsIgnoreCase(writeConcern)) {
return WriteConcern.JOURNAL_SAFE;
}
if ("REPLICAS_SAFE".equalsIgnoreCase(writeConcern)) {
return WriteConcern.REPLICAS_SAFE;
}
return WriteConcern.ACKNOWLEDGED;
}