5
0
mirror of https://github.com/apache/sqoop.git synced 2025-05-03 10:10:08 +08:00

SQOOP-1469: Sqoop2: Validations: Rename constants in Status class

(Jarek Jarcec Cecho via Abraham Elmahrek)
This commit is contained in:
Abraham Elmahrek 2014-11-03 13:18:09 -08:00
parent 9e1f4cbaa8
commit d6319e3a7b
54 changed files with 138 additions and 142 deletions

View File

@ -20,39 +20,37 @@
/** /**
* Severity of validation message. * Severity of validation message.
* *
* Fine: * OK:
* Everything is correct (default state). * Everything is correct (default state).
* *
* Warning: * WARNING:
* Warning is something suspicious, potentially wrong but something that * Warning is something suspicious, potentially wrong but something that
* can be ignored. For example in case of JDBC URL element, warning would * can be ignored. For example in case of JDBC URL element, warning would
* be if specified host is not responding - it's warning because specified * be if specified host is not responding - it's warning because specified
* URL might be wrong. However at the same time URL might be right as only * URL might be wrong. However at the same time URL might be right as only
* target host might be down. * target host might be down.
* *
* Error: * ERROR:
* Error represents unacceptable element content. For example in case of JDBC * Error represents unacceptable element content. For example in case of JDBC
* URL path, error would be empty element or element containing invalid URL. * URL path, error would be empty element or element containing invalid URL.
*
* TODO: This should really be renamed to "severity"
*/ */
public enum Status { public enum Status {
/** /**
* There are no issues, no warnings. Everything is correct. * There are no issues, no warnings. Everything is correct.
*/ */
FINE, // TODO: Rename to "OK" OK,
/** /**
* Validated entity is correct enough to be processed. There might be some * Validated entity is correct enough to be processed. There might be some
* warnings, but no errors. * warnings, but no errors.
*/ */
ACCEPTABLE, // TODO: Rename to "WARNING" WARNING,
/** /**
* There are serious issues with validated entity. We can't proceed until * There are serious issues with validated entity. We can't proceed until
* reported issues will be resolved. * reported issues will be resolved.
*/ */
UNACCEPTABLE, // TODO: Rename to "ERROR" ERROR,
; ;
@ -63,7 +61,7 @@ public enum Status {
* @return The worst status * @return The worst status
*/ */
public static Status getWorstStatus(Status ... statuses) { public static Status getWorstStatus(Status ... statuses) {
Status finalStatus = FINE; Status finalStatus = OK;
for (Status status : statuses) { for (Status status : statuses) {
if (finalStatus.compareTo(status) < 1) { if (finalStatus.compareTo(status) < 1) {
@ -80,7 +78,7 @@ public static Status getWorstStatus(Status ... statuses) {
* @return True if we can proceed with processing * @return True if we can proceed with processing
*/ */
public boolean canProceed() { public boolean canProceed() {
return this == FINE || this == ACCEPTABLE; return this == OK || this == WARNING;
} }
/** /**
@ -89,6 +87,6 @@ public boolean canProceed() {
* @return Default validation status * @return Default validation status
*/ */
public static Status getDefault() { public static Status getDefault() {
return FINE; return OK;
} }
} }

View File

@ -29,7 +29,7 @@ public void validate(String klass) {
try { try {
Class.forName(klass); Class.forName(klass);
} catch (ClassNotFoundException e) { } catch (ClassNotFoundException e) {
addMessage(new Message(Status.UNACCEPTABLE, "Class not found")); addMessage(new Message(Status.ERROR, "Class not found"));
} }
} }
} }

View File

@ -26,7 +26,7 @@ public class Contains extends AbstractValidator<String> {
@Override @Override
public void validate(String str) { public void validate(String str) {
if(str == null || !str.contains(getStringArgument())) { if(str == null || !str.contains(getStringArgument())) {
addMessage(Status.UNACCEPTABLE, "String must contain substring: " + getStringArgument()); addMessage(Status.ERROR, "String must contain substring: " + getStringArgument());
} }
} }
} }

View File

@ -28,7 +28,7 @@ public class NotEmpty extends AbstractValidator<String> {
@Override @Override
public void validate(String instance) { public void validate(String instance) {
if (instance == null || instance.isEmpty()) { if (instance == null || instance.isEmpty()) {
addMessage(Status.UNACCEPTABLE, "Can't be null nor empty"); addMessage(Status.ERROR, "Can't be null nor empty");
} }
} }
} }

View File

@ -26,7 +26,7 @@ public class NotNull<T> extends AbstractValidator<T> {
@Override @Override
public void validate(T instance) { public void validate(T instance) {
if (instance == null) { if (instance == null) {
addMessage(Status.UNACCEPTABLE, "Can't be null"); addMessage(Status.ERROR, "Can't be null");
} }
} }
} }

View File

@ -26,7 +26,7 @@ public class NullOrContains extends AbstractValidator<String> {
@Override @Override
public void validate(String str) { public void validate(String str) {
if(str != null && !str.contains(getStringArgument())) { if(str != null && !str.contains(getStringArgument())) {
addMessage(Status.UNACCEPTABLE, "String must contain substring: " + getStringArgument()); addMessage(Status.ERROR, "String must contain substring: " + getStringArgument());
} }
} }
} }

View File

@ -26,7 +26,7 @@ public class StartsWith extends AbstractValidator<String> {
@Override @Override
public void validate(String str) { public void validate(String str) {
if(str == null || !str.startsWith(getStringArgument())) { if(str == null || !str.startsWith(getStringArgument())) {
addMessage(Status.UNACCEPTABLE, "String must start with: " + getStringArgument()); addMessage(Status.ERROR, "String must start with: " + getStringArgument());
} }
} }
} }

View File

@ -81,7 +81,7 @@ public void testId() {
public void verifyResultA(ConfigValidationResult result) { public void verifyResultA(ConfigValidationResult result) {
assertNotNull(result); assertNotNull(result);
assertEquals(Status.UNACCEPTABLE, result.getStatus()); assertEquals(Status.ERROR, result.getStatus());
Map<String, List<Message>> messages = result.getMessages(); Map<String, List<Message>> messages = result.getMessages();
assertEquals(1, messages.size()); assertEquals(1, messages.size());
@ -91,18 +91,18 @@ public void verifyResultA(ConfigValidationResult result) {
assertNotNull(messagesA); assertNotNull(messagesA);
assertEquals(2, messagesA.size()); assertEquals(2, messagesA.size());
assertEquals(Status.ACCEPTABLE, messagesA.get(0).getStatus()); assertEquals(Status.WARNING, messagesA.get(0).getStatus());
assertEquals("A", messagesA.get(0).getMessage()); assertEquals("A", messagesA.get(0).getMessage());
assertEquals(Status.UNACCEPTABLE, messagesA.get(1).getStatus()); assertEquals(Status.ERROR, messagesA.get(1).getStatus());
assertEquals("B", messagesA.get(1).getMessage()); assertEquals("B", messagesA.get(1).getMessage());
} }
public ConfigValidationResult getResultA() { public ConfigValidationResult getResultA() {
ConfigValidationResult result = new ConfigValidationResult(); ConfigValidationResult result = new ConfigValidationResult();
List<Message> messages = new LinkedList<Message>(); List<Message> messages = new LinkedList<Message>();
messages.add(new Message(Status.ACCEPTABLE, "A")); messages.add(new Message(Status.WARNING, "A"));
messages.add(new Message(Status.UNACCEPTABLE, "B")); messages.add(new Message(Status.ERROR, "B"));
result.addMessages("A", messages); result.addMessages("A", messages);
return result; return result;
} }

View File

@ -35,7 +35,7 @@ public class TestMValidatedElement {
public void testInitialization() { public void testInitialization() {
MValidatedElement input = new MIntegerInput("input", false); MValidatedElement input = new MIntegerInput("input", false);
assertEquals("input", input.getName()); assertEquals("input", input.getName());
assertEquals(Status.FINE, input.getValidationStatus()); assertEquals(Status.OK, input.getValidationStatus());
} }
/** /**
@ -46,22 +46,22 @@ public void testVarious() {
MValidatedElement input = new MIntegerInput("input", false); MValidatedElement input = new MIntegerInput("input", false);
// Default status // Default status
assertEquals(Status.FINE, input.getValidationStatus()); assertEquals(Status.OK, input.getValidationStatus());
// Add a message // Add a message
input.addValidationMessage(new Message(Status.ACCEPTABLE, "MY_MESSAGE")); input.addValidationMessage(new Message(Status.WARNING, "MY_MESSAGE"));
assertEquals(Status.ACCEPTABLE, input.getValidationStatus()); assertEquals(Status.WARNING, input.getValidationStatus());
assertEquals(1, input.getValidationMessages().size()); assertEquals(1, input.getValidationMessages().size());
assertEquals("MY_MESSAGE", input.getValidationMessages().get(0).getMessage()); assertEquals("MY_MESSAGE", input.getValidationMessages().get(0).getMessage());
// Reset // Reset
input.resetValidationMessages(); input.resetValidationMessages();
assertEquals(Status.FINE, input.getValidationStatus()); assertEquals(Status.OK, input.getValidationStatus());
assertEquals(0, input.getValidationMessages().size()); assertEquals(0, input.getValidationMessages().size());
// Set unacceptable status // Set unacceptable status
input.addValidationMessage(new Message(Status.UNACCEPTABLE, "MY_MESSAGE")); input.addValidationMessage(new Message(Status.ERROR, "MY_MESSAGE"));
assertEquals(Status.UNACCEPTABLE, input.getValidationStatus()); assertEquals(Status.ERROR, input.getValidationStatus());
assertEquals(1, input.getValidationMessages().size()); assertEquals(1, input.getValidationMessages().size());
assertEquals("MY_MESSAGE", input.getValidationMessages().get(0).getMessage()); assertEquals("MY_MESSAGE", input.getValidationMessages().get(0).getMessage());
} }

View File

@ -28,26 +28,26 @@ public class TestStatus {
@Test @Test
public void testGetWorstStatus() { public void testGetWorstStatus() {
// Comparing itself with itself // Comparing itself with itself
assertEquals(Status.FINE, assertEquals(Status.OK,
Status.getWorstStatus(Status.FINE)); Status.getWorstStatus(Status.OK));
assertEquals(Status.FINE, assertEquals(Status.OK,
Status.getWorstStatus(Status.FINE, Status.FINE)); Status.getWorstStatus(Status.OK, Status.OK));
assertEquals(Status.ACCEPTABLE, assertEquals(Status.WARNING,
Status.getWorstStatus(Status.ACCEPTABLE, Status.ACCEPTABLE)); Status.getWorstStatus(Status.WARNING, Status.WARNING));
assertEquals(Status.UNACCEPTABLE, assertEquals(Status.ERROR,
Status.getWorstStatus(Status.UNACCEPTABLE, Status.UNACCEPTABLE)); Status.getWorstStatus(Status.ERROR, Status.ERROR));
// Retriving the worst option // Retriving the worst option
assertEquals(Status.UNACCEPTABLE, assertEquals(Status.ERROR,
Status.getWorstStatus(Status.FINE, Status.UNACCEPTABLE)); Status.getWorstStatus(Status.OK, Status.ERROR));
assertEquals(Status.ACCEPTABLE, assertEquals(Status.WARNING,
Status.getWorstStatus(Status.FINE, Status.ACCEPTABLE)); Status.getWorstStatus(Status.OK, Status.WARNING));
} }
@Test @Test
public void testCanProceed() { public void testCanProceed() {
assertTrue(Status.FINE.canProceed()); assertTrue(Status.OK.canProceed());
assertTrue(Status.ACCEPTABLE.canProceed()); assertTrue(Status.WARNING.canProceed());
assertFalse(Status.UNACCEPTABLE.canProceed()); assertFalse(Status.ERROR.canProceed());
} }
} }

View File

@ -44,10 +44,10 @@ public static class ConfigValidator extends AbstractValidator<ConfigA> {
@Override @Override
public void validate(ConfigA config) { public void validate(ConfigA config) {
if(config.notNull == null) { if(config.notNull == null) {
addMessage(Status.UNACCEPTABLE, "null"); addMessage(Status.ERROR, "null");
} }
if("error".equals(config.notNull)) { if("error".equals(config.notNull)) {
addMessage(Status.UNACCEPTABLE, "error"); addMessage(Status.ERROR, "error");
} }
} }
} }
@ -62,21 +62,21 @@ public void testValidateConfig() {
// Null string should fail on Input level and should not call config level validators // Null string should fail on Input level and should not call config level validators
config.notNull = null; config.notNull = null;
result = runner.validateConfig("configName", config); result = runner.validateConfig("configName", config);
assertEquals(Status.UNACCEPTABLE, result.getStatus()); assertEquals(Status.ERROR, result.getStatus());
assertEquals(1, result.getMessages().size()); assertEquals(1, result.getMessages().size());
assertTrue(result.getMessages().containsKey("configName.notNull")); assertTrue(result.getMessages().containsKey("configName.notNull"));
// String "error" should trigger config level error, but not Input level // String "error" should trigger config level error, but not Input level
config.notNull = "error"; config.notNull = "error";
result = runner.validateConfig("configName", config); result = runner.validateConfig("configName", config);
assertEquals(Status.UNACCEPTABLE, result.getStatus()); assertEquals(Status.ERROR, result.getStatus());
assertEquals(1, result.getMessages().size()); assertEquals(1, result.getMessages().size());
assertTrue(result.getMessages().containsKey("configName")); assertTrue(result.getMessages().containsKey("configName"));
// Acceptable state // Acceptable state
config.notNull = "This is truly random string"; config.notNull = "This is truly random string";
result = runner.validateConfig("configName", config); result = runner.validateConfig("configName", config);
assertEquals(Status.FINE, result.getStatus()); assertEquals(Status.OK, result.getStatus());
assertEquals(0, result.getMessages().size()); assertEquals(0, result.getMessages().size());
} }
@ -100,7 +100,7 @@ public void testMultipleValidatorsOnSingleInput() {
config.str = null; config.str = null;
result = runner.validateConfig("configName", config); result = runner.validateConfig("configName", config);
assertEquals(Status.UNACCEPTABLE, result.getStatus()); assertEquals(Status.ERROR, result.getStatus());
assertEquals(1, result.getMessages().size()); assertEquals(1, result.getMessages().size());
assertTrue(result.getMessages().containsKey("configName.str")); assertTrue(result.getMessages().containsKey("configName.str"));
assertEquals(2, result.getMessages().get("configName.str").size()); assertEquals(2, result.getMessages().get("configName.str").size());
@ -115,14 +115,14 @@ public void testValidatorWithParameters() {
// Sub string not found // Sub string not found
config.str = "Mordor"; config.str = "Mordor";
result = runner.validateConfig("configName", config); result = runner.validateConfig("configName", config);
assertEquals(Status.UNACCEPTABLE, result.getStatus()); assertEquals(Status.ERROR, result.getStatus());
assertEquals(1, result.getMessages().size()); assertEquals(1, result.getMessages().size());
assertTrue(result.getMessages().containsKey("configName.str")); assertTrue(result.getMessages().containsKey("configName.str"));
// Sub string found // Sub string found
config.str = "Morfindmedor"; config.str = "Morfindmedor";
result = runner.validateConfig("configName", config); result = runner.validateConfig("configName", config);
assertEquals(Status.FINE, result.getStatus()); assertEquals(Status.OK, result.getStatus());
assertEquals(0, result.getMessages().size()); assertEquals(0, result.getMessages().size());
} }
@ -137,10 +137,10 @@ public static class ClassValidator extends AbstractValidator<ConfigurationA> {
@Override @Override
public void validate(ConfigurationA conf) { public void validate(ConfigurationA conf) {
if("error".equals(conf.formA.notNull)) { if("error".equals(conf.formA.notNull)) {
addMessage(Status.UNACCEPTABLE, "error"); addMessage(Status.ERROR, "error");
} }
if("conf-error".equals(conf.formA.notNull)) { if("conf-error".equals(conf.formA.notNull)) {
addMessage(Status.UNACCEPTABLE, "conf-error"); addMessage(Status.ERROR, "conf-error");
} }
} }
} }
@ -155,28 +155,28 @@ public void testValidate() {
// Null string should fail on Input level and should not call config nor class level validators // Null string should fail on Input level and should not call config nor class level validators
conf.formA.notNull = null; conf.formA.notNull = null;
result = runner.validate(conf); result = runner.validate(conf);
assertEquals(Status.UNACCEPTABLE, result.getStatus()); assertEquals(Status.ERROR, result.getStatus());
assertEquals(1, result.getMessages().size()); assertEquals(1, result.getMessages().size());
assertTrue(result.getMessages().containsKey("formA.notNull")); assertTrue(result.getMessages().containsKey("formA.notNull"));
// String "error" should trigger config level error, but not Input nor class level // String "error" should trigger config level error, but not Input nor class level
conf.formA.notNull = "error"; conf.formA.notNull = "error";
result = runner.validate(conf); result = runner.validate(conf);
assertEquals(Status.UNACCEPTABLE, result.getStatus()); assertEquals(Status.ERROR, result.getStatus());
assertEquals(1, result.getMessages().size()); assertEquals(1, result.getMessages().size());
assertTrue(result.getMessages().containsKey("formA")); assertTrue(result.getMessages().containsKey("formA"));
// String "conf-error" should trigger class level error, but not Input nor Config level // String "conf-error" should trigger class level error, but not Input nor Config level
conf.formA.notNull = "conf-error"; conf.formA.notNull = "conf-error";
result = runner.validate(conf); result = runner.validate(conf);
assertEquals(Status.UNACCEPTABLE, result.getStatus()); assertEquals(Status.ERROR, result.getStatus());
assertEquals(1, result.getMessages().size()); assertEquals(1, result.getMessages().size());
assertTrue(result.getMessages().containsKey("")); assertTrue(result.getMessages().containsKey(""));
// Valid string // Valid string
conf.formA.notNull = "Valid string"; conf.formA.notNull = "Valid string";
result = runner.validate(conf); result = runner.validate(conf);
assertEquals(Status.FINE, result.getStatus()); assertEquals(Status.OK, result.getStatus());
assertEquals(0, result.getMessages().size()); assertEquals(0, result.getMessages().size());
} }
} }

View File

@ -43,6 +43,6 @@ public void test() {
validator.validate("net.jarcec.super.private.project.Main"); validator.validate("net.jarcec.super.private.project.Main");
assertEquals(1, validator.getMessages().size()); assertEquals(1, validator.getMessages().size());
messages = validator.getMessages(); messages = validator.getMessages();
assertEquals(Status.UNACCEPTABLE, messages.get(0).getStatus()); assertEquals(Status.ERROR, messages.get(0).getStatus());
} }
} }

View File

@ -34,56 +34,56 @@ public void test() {
// Default, no string argument set // Default, no string argument set
validator.validate("str"); validator.validate("str");
assertEquals(Status.FINE, validator.getStatus()); assertEquals(Status.OK, validator.getStatus());
assertEquals(0, validator.getMessages().size()); assertEquals(0, validator.getMessages().size());
// Searched substring is entire string // Searched substring is entire string
validator.reset(); validator.reset();
validator.setStringArgument("str"); validator.setStringArgument("str");
validator.validate("str"); validator.validate("str");
assertEquals(Status.FINE, validator.getStatus()); assertEquals(Status.OK, validator.getStatus());
assertEquals(0, validator.getMessages().size()); assertEquals(0, validator.getMessages().size());
// Just starts with // Just starts with
validator.reset(); validator.reset();
validator.setStringArgument("str"); validator.setStringArgument("str");
validator.validate("straaaaa"); validator.validate("straaaaa");
assertEquals(Status.FINE, validator.getStatus()); assertEquals(Status.OK, validator.getStatus());
assertEquals(0, validator.getMessages().size()); assertEquals(0, validator.getMessages().size());
// Ends with // Ends with
validator.reset(); validator.reset();
validator.setStringArgument("str"); validator.setStringArgument("str");
validator.validate("aaastr"); validator.validate("aaastr");
assertEquals(Status.FINE, validator.getStatus()); assertEquals(Status.OK, validator.getStatus());
assertEquals(0, validator.getMessages().size()); assertEquals(0, validator.getMessages().size());
// In the middle // In the middle
validator.reset(); validator.reset();
validator.setStringArgument("str"); validator.setStringArgument("str");
validator.validate("aaastraaa"); validator.validate("aaastraaa");
assertEquals(Status.FINE, validator.getStatus()); assertEquals(Status.OK, validator.getStatus());
assertEquals(0, validator.getMessages().size()); assertEquals(0, validator.getMessages().size());
// Null string // Null string
validator.reset(); validator.reset();
validator.setStringArgument("str"); validator.setStringArgument("str");
validator.validate(null); validator.validate(null);
assertEquals(Status.UNACCEPTABLE, validator.getStatus()); assertEquals(Status.ERROR, validator.getStatus());
assertEquals(1, validator.getMessages().size()); assertEquals(1, validator.getMessages().size());
// Empty string // Empty string
validator.reset(); validator.reset();
validator.setStringArgument("str"); validator.setStringArgument("str");
validator.validate(""); validator.validate("");
assertEquals(Status.UNACCEPTABLE, validator.getStatus()); assertEquals(Status.ERROR, validator.getStatus());
assertEquals(1, validator.getMessages().size()); assertEquals(1, validator.getMessages().size());
// "Random" string // "Random" string
validator.reset(); validator.reset();
validator.setStringArgument("str"); validator.setStringArgument("str");
validator.validate("Ahoj tady je meduza"); validator.validate("Ahoj tady je meduza");
assertEquals(Status.UNACCEPTABLE, validator.getStatus()); assertEquals(Status.ERROR, validator.getStatus());
assertEquals(1, validator.getMessages().size()); assertEquals(1, validator.getMessages().size());
} }

View File

@ -42,7 +42,7 @@ public void test() {
validator.validate(""); validator.validate("");
assertEquals(1, validator.getMessages().size()); assertEquals(1, validator.getMessages().size());
messages = validator.getMessages(); messages = validator.getMessages();
assertEquals(Status.UNACCEPTABLE, messages.get(0).getStatus()); assertEquals(Status.ERROR, messages.get(0).getStatus());
validator.reset(); validator.reset();
assertEquals(0, validator.getMessages().size()); assertEquals(0, validator.getMessages().size());
@ -50,6 +50,6 @@ public void test() {
validator.validate(null); validator.validate(null);
assertEquals(1, validator.getMessages().size()); assertEquals(1, validator.getMessages().size());
messages = validator.getMessages(); messages = validator.getMessages();
assertEquals(Status.UNACCEPTABLE, messages.get(0).getStatus()); assertEquals(Status.ERROR, messages.get(0).getStatus());
} }
} }

View File

@ -46,6 +46,6 @@ public void test() {
List<Message> messages = validator.getMessages(); List<Message> messages = validator.getMessages();
Message msg = messages.get(0); Message msg = messages.get(0);
assertEquals(Status.UNACCEPTABLE, msg.getStatus()); assertEquals(Status.ERROR, msg.getStatus());
} }
} }

View File

@ -34,63 +34,63 @@ public void test() {
// Default, no string argument set // Default, no string argument set
validator.validate("str"); validator.validate("str");
assertEquals(Status.FINE, validator.getStatus()); assertEquals(Status.OK, validator.getStatus());
assertEquals(0, validator.getMessages().size()); assertEquals(0, validator.getMessages().size());
// Searched substring is entire string // Searched substring is entire string
validator.reset(); validator.reset();
validator.setStringArgument("str"); validator.setStringArgument("str");
validator.validate("str"); validator.validate("str");
assertEquals(Status.FINE, validator.getStatus()); assertEquals(Status.OK, validator.getStatus());
assertEquals(0, validator.getMessages().size()); assertEquals(0, validator.getMessages().size());
// Just starts with // Just starts with
validator.reset(); validator.reset();
validator.setStringArgument("str"); validator.setStringArgument("str");
validator.validate("straaaaa"); validator.validate("straaaaa");
assertEquals(Status.FINE, validator.getStatus()); assertEquals(Status.OK, validator.getStatus());
assertEquals(0, validator.getMessages().size()); assertEquals(0, validator.getMessages().size());
// Ends with // Ends with
validator.reset(); validator.reset();
validator.setStringArgument("str"); validator.setStringArgument("str");
validator.validate("aaastr"); validator.validate("aaastr");
assertEquals(Status.FINE, validator.getStatus()); assertEquals(Status.OK, validator.getStatus());
assertEquals(0, validator.getMessages().size()); assertEquals(0, validator.getMessages().size());
// In the middle // In the middle
validator.reset(); validator.reset();
validator.setStringArgument("str"); validator.setStringArgument("str");
validator.validate("aaastraaa"); validator.validate("aaastraaa");
assertEquals(Status.FINE, validator.getStatus()); assertEquals(Status.OK, validator.getStatus());
assertEquals(0, validator.getMessages().size()); assertEquals(0, validator.getMessages().size());
// Repitition // Repitition
validator.reset(); validator.reset();
validator.setStringArgument("str"); validator.setStringArgument("str");
validator.validate("aaastraaastraaa"); validator.validate("aaastraaastraaa");
assertEquals(Status.FINE, validator.getStatus()); assertEquals(Status.OK, validator.getStatus());
assertEquals(0, validator.getMessages().size()); assertEquals(0, validator.getMessages().size());
// Null string // Null string
validator.reset(); validator.reset();
validator.setStringArgument("str"); validator.setStringArgument("str");
validator.validate(null); validator.validate(null);
assertEquals(Status.FINE, validator.getStatus()); assertEquals(Status.OK, validator.getStatus());
assertEquals(0, validator.getMessages().size()); assertEquals(0, validator.getMessages().size());
// Empty string // Empty string
validator.reset(); validator.reset();
validator.setStringArgument("str"); validator.setStringArgument("str");
validator.validate(""); validator.validate("");
assertEquals(Status.UNACCEPTABLE, validator.getStatus()); assertEquals(Status.ERROR, validator.getStatus());
assertEquals(1, validator.getMessages().size()); assertEquals(1, validator.getMessages().size());
// "Random" string // "Random" string
validator.reset(); validator.reset();
validator.setStringArgument("str"); validator.setStringArgument("str");
validator.validate("Ahoj tady je meduza"); validator.validate("Ahoj tady je meduza");
assertEquals(Status.UNACCEPTABLE, validator.getStatus()); assertEquals(Status.ERROR, validator.getStatus());
assertEquals(1, validator.getMessages().size()); assertEquals(1, validator.getMessages().size());
} }

View File

@ -34,40 +34,40 @@ public void test() {
// Default, no string argument set // Default, no string argument set
validator.validate("str"); validator.validate("str");
assertEquals(Status.FINE, validator.getStatus()); assertEquals(Status.OK, validator.getStatus());
assertEquals(0, validator.getMessages().size()); assertEquals(0, validator.getMessages().size());
// Searched substring is entire string // Searched substring is entire string
validator.validate("str"); validator.validate("str");
assertEquals(Status.FINE, validator.getStatus()); assertEquals(Status.OK, validator.getStatus());
assertEquals(0, validator.getMessages().size()); assertEquals(0, validator.getMessages().size());
// Just starts with // Just starts with
validator.reset(); validator.reset();
validator.setStringArgument("str"); validator.setStringArgument("str");
validator.validate("strstr"); validator.validate("strstr");
assertEquals(Status.FINE, validator.getStatus()); assertEquals(Status.OK, validator.getStatus());
assertEquals(0, validator.getMessages().size()); assertEquals(0, validator.getMessages().size());
// Null string // Null string
validator.reset(); validator.reset();
validator.setStringArgument("str"); validator.setStringArgument("str");
validator.validate(null); validator.validate(null);
assertEquals(Status.UNACCEPTABLE, validator.getStatus()); assertEquals(Status.ERROR, validator.getStatus());
assertEquals(1, validator.getMessages().size()); assertEquals(1, validator.getMessages().size());
// Empty string // Empty string
validator.reset(); validator.reset();
validator.setStringArgument("str"); validator.setStringArgument("str");
validator.validate(""); validator.validate("");
assertEquals(Status.UNACCEPTABLE, validator.getStatus()); assertEquals(Status.ERROR, validator.getStatus());
assertEquals(1, validator.getMessages().size()); assertEquals(1, validator.getMessages().size());
// "Random" string // "Random" string
validator.reset(); validator.reset();
validator.setStringArgument("str"); validator.setStringArgument("str");
validator.validate("Ahoj tady je meduza"); validator.validate("Ahoj tady je meduza");
assertEquals(Status.UNACCEPTABLE, validator.getStatus()); assertEquals(Status.ERROR, validator.getStatus());
assertEquals(1, validator.getMessages().size()); assertEquals(1, validator.getMessages().size());
} }

View File

@ -30,8 +30,8 @@ public class TestValidator {
public static class ValidatorImpl extends AbstractValidator<String> { public static class ValidatorImpl extends AbstractValidator<String> {
@Override @Override
public void validate(String msg) { public void validate(String msg) {
addMessage(Status.FINE, msg); addMessage(Status.OK, msg);
addMessage(new Message(Status.UNACCEPTABLE, "Prefix: " + msg)); addMessage(new Message(Status.ERROR, "Prefix: " + msg));
} }
} }
@ -44,11 +44,11 @@ public void test() {
assertEquals(2, validator.getMessages().size()); assertEquals(2, validator.getMessages().size());
Message msg = validator.getMessages().get(0); Message msg = validator.getMessages().get(0);
assertEquals(Status.FINE, msg.getStatus()); assertEquals(Status.OK, msg.getStatus());
assertEquals("X", msg.getMessage()); assertEquals("X", msg.getMessage());
msg = validator.getMessages().get(1); msg = validator.getMessages().get(1);
assertEquals(Status.UNACCEPTABLE, msg.getStatus()); assertEquals(Status.ERROR, msg.getStatus());
assertEquals("Prefix: X", msg.getMessage()); assertEquals("Prefix: X", msg.getMessage());
validator.reset(); validator.reset();

View File

@ -55,13 +55,13 @@ public static class ConfigValidator extends AbstractValidator<FromJobConfig> {
@Override @Override
public void validate(FromJobConfig config) { public void validate(FromJobConfig config) {
if (config.tableName == null && config.sql == null) { if (config.tableName == null && config.sql == null) {
addMessage(Status.UNACCEPTABLE, "Either table name or SQL must be specified"); addMessage(Status.ERROR, "Either table name or SQL must be specified");
} }
if (config.tableName != null && config.sql != null) { if (config.tableName != null && config.sql != null) {
addMessage(Status.UNACCEPTABLE, "Both table name and SQL cannot be specified"); addMessage(Status.ERROR, "Both table name and SQL cannot be specified");
} }
if (config.schemaName != null && config.sql != null) { if (config.schemaName != null && config.sql != null) {
addMessage(Status.UNACCEPTABLE, "Both schema name and SQL cannot be specified"); addMessage(Status.ERROR, "Both schema name and SQL cannot be specified");
} }
} }
} }

View File

@ -57,7 +57,7 @@ public void validate(LinkConfig linkConfig) {
try { try {
DriverManager.getConnection(linkConfig.connectionString, linkConfig.username, linkConfig.password); DriverManager.getConnection(linkConfig.connectionString, linkConfig.username, linkConfig.password);
} catch (SQLException e) { } catch (SQLException e) {
addMessage(Status.ACCEPTABLE, "Can't connect to the database with given credentials: " + e.getMessage()); addMessage(Status.WARNING, "Can't connect to the database with given credentials: " + e.getMessage());
} }
} }
} }

View File

@ -50,17 +50,17 @@ public static class ConfigValidator extends AbstractValidator<ToJobConfig> {
@Override @Override
public void validate(ToJobConfig config) { public void validate(ToJobConfig config) {
if (config.tableName == null && config.sql == null) { if (config.tableName == null && config.sql == null) {
addMessage(Status.UNACCEPTABLE, "Either table name or SQL must be specified"); addMessage(Status.ERROR, "Either table name or SQL must be specified");
} }
if (config.tableName != null && config.sql != null) { if (config.tableName != null && config.sql != null) {
addMessage(Status.UNACCEPTABLE, "Both table name and SQL cannot be specified"); addMessage(Status.ERROR, "Both table name and SQL cannot be specified");
} }
if (config.tableName == null && config.stageTableName != null) { if (config.tableName == null && config.stageTableName != null) {
addMessage(Status.UNACCEPTABLE, addMessage(Status.ERROR,
"Stage table name cannot be specified without specifying table name"); "Stage table name cannot be specified without specifying table name");
} }
if (config.stageTableName == null && config.shouldClearStageTable != null) { if (config.stageTableName == null && config.shouldClearStageTable != null) {
addMessage(Status.UNACCEPTABLE, addMessage(Status.ERROR,
"Should Clear stage table cannot be specified without specifying the name of the stage table."); "Should Clear stage table cannot be specified without specifying the name of the stage table.");
} }
} }

View File

@ -293,7 +293,7 @@ public void testClearStageTableValidation() throws Exception {
ConfigValidationResult result = validationRunner.validate(jobConfig); ConfigValidationResult result = validationRunner.validate(jobConfig);
assertEquals("User should not specify clear stage table flag without " + assertEquals("User should not specify clear stage table flag without " +
"specifying name of the stage table", "specifying name of the stage table",
Status.UNACCEPTABLE, Status.ERROR,
result.getStatus()); result.getStatus());
assertTrue(result.getMessages().containsKey( assertTrue(result.getMessages().containsKey(
"toJobConfig")); "toJobConfig"));
@ -302,7 +302,7 @@ public void testClearStageTableValidation() throws Exception {
result = validationRunner.validate(jobConfig); result = validationRunner.validate(jobConfig);
assertEquals("User should not specify clear stage table flag without " + assertEquals("User should not specify clear stage table flag without " +
"specifying name of the stage table", "specifying name of the stage table",
Status.UNACCEPTABLE, Status.ERROR,
result.getStatus()); result.getStatus());
assertTrue(result.getMessages().containsKey( assertTrue(result.getMessages().containsKey(
"toJobConfig")); "toJobConfig"));
@ -322,7 +322,7 @@ public void testStageTableWithoutTable() throws Exception {
ConfigValidationRunner validationRunner = new ConfigValidationRunner(); ConfigValidationRunner validationRunner = new ConfigValidationRunner();
ConfigValidationResult result = validationRunner.validate(jobConfig); ConfigValidationResult result = validationRunner.validate(jobConfig);
assertEquals("Stage table name cannot be specified without specifying " + assertEquals("Stage table name cannot be specified without specifying " +
"table name", Status.UNACCEPTABLE, result.getStatus()); "table name", Status.ERROR, result.getStatus());
assertTrue(result.getMessages().containsKey( assertTrue(result.getMessages().containsKey(
"toJobConfig")); "toJobConfig"));
} }

View File

@ -38,7 +38,7 @@ public void validate(LinkConfig config) {
if (config.uri != null) { if (config.uri != null) {
Matcher matcher = URI_PATTERN.matcher(config.uri); Matcher matcher = URI_PATTERN.matcher(config.uri);
if (!matcher.matches()) { if (!matcher.matches()) {
addMessage(Status.UNACCEPTABLE, addMessage(Status.ERROR,
"Invalid URI" + config.uri + ". URI must either be null or a valid URI. Here are a few valid example URIs:" "Invalid URI" + config.uri + ". URI must either be null or a valid URI. Here are a few valid example URIs:"
+ " hdfs://example.com:8020/, hdfs://example.com/, file:///, file:///tmp, file://localhost/tmp"); + " hdfs://example.com:8020/, hdfs://example.com/, file:///, file:///tmp, file://localhost/tmp");
} }

View File

@ -44,12 +44,12 @@ public void validate(ToJobConfig conf) {
if(conf.customCompression != null && if(conf.customCompression != null &&
conf.customCompression.trim().length() > 0 && conf.customCompression.trim().length() > 0 &&
conf.compression != ToCompression.CUSTOM) { conf.compression != ToCompression.CUSTOM) {
addMessage(Status.UNACCEPTABLE, "Custom compression codec should be blank as " + conf.compression + " is being used"); addMessage(Status.ERROR, "Custom compression codec should be blank as " + conf.compression + " is being used");
} }
if(conf.compression == ToCompression.CUSTOM && if(conf.compression == ToCompression.CUSTOM &&
(conf.customCompression == null || conf.customCompression.trim().length() == 0)) { (conf.customCompression == null || conf.customCompression.trim().length() == 0)) {
addMessage(Status.UNACCEPTABLE, "Custom compression field is blank."); addMessage(Status.ERROR, "Custom compression field is blank.");
} }
} }
} }

View File

@ -800,7 +800,7 @@ public static class InvalidConfiguration {
public static class InternalValidator extends AbstractValidator { public static class InternalValidator extends AbstractValidator {
@Override @Override
public void validate(Object instance) { public void validate(Object instance) {
addMessage(Status.UNACCEPTABLE, "Simply because."); addMessage(Status.ERROR, "Simply because.");
} }
} }
} }

View File

@ -114,11 +114,11 @@ List of status code
+------------------+------------------------------------------------------------------------------------------------------------+ +------------------+------------------------------------------------------------------------------------------------------------+
| Function | Description | | Function | Description |
+==================+============================================================================================================+ +==================+============================================================================================================+
| ``FINE`` | There are no issues, no warnings. | | ``OK`` | There are no issues, no warnings. |
+------------------+------------------------------------------------------------------------------------------------------------+ +------------------+------------------------------------------------------------------------------------------------------------+
| ``ACCEPTABLE`` | Validated entity is correct enough to be processed. There might be some warnings, but no errors. | | ``WARNING`` | Validated entity is correct enough to be processed. There might be some warnings, but no errors. |
+------------------+------------------------------------------------------------------------------------------------------------+ +------------------+------------------------------------------------------------------------------------------------------------+
| ``UNACCEPTABLE`` | There are serious issues with validated entity. We can't proceed until reported issues will be resolved. | | ``ERROR`` | There are serious issues with validated entity. We can't proceed until reported issues will be resolved. |
+------------------+------------------------------------------------------------------------------------------------------------+ +------------------+------------------------------------------------------------------------------------------------------------+
View Error or Warning message View Error or Warning message

View File

@ -69,7 +69,7 @@ private Status cloneJob(Long jobId, List<String> args, boolean isInteractive) th
job.getConnectorId(Direction.TO)); job.getConnectorId(Direction.TO));
ResourceBundle driverConfigBundle = client.getDriverConfigBundle(); ResourceBundle driverConfigBundle = client.getDriverConfigBundle();
Status status = Status.FINE; Status status = Status.OK;
// Remove persistent id as we're making a clone // Remove persistent id as we're making a clone
job.setPersistenceId(MPersistableEntity.PERSISTANCE_ID_DEFAULT); job.setPersistenceId(MPersistableEntity.PERSISTANCE_ID_DEFAULT);

View File

@ -65,7 +65,7 @@ private Status cloneLink(Long connectionId, List<String> args, boolean isInterac
// Remove persistent id as we're making a clone // Remove persistent id as we're making a clone
connection.setPersistenceId(MPersistableEntity.PERSISTANCE_ID_DEFAULT); connection.setPersistenceId(MPersistableEntity.PERSISTANCE_ID_DEFAULT);
Status status = Status.FINE; Status status = Status.OK;
ResourceBundle linkConfigBundle = client.getConnectorConfigBundle(connection.getConnectorId()); ResourceBundle linkConfigBundle = client.getConnectorConfigBundle(connection.getConnectorId());

View File

@ -79,7 +79,7 @@ private Status createJob(Long fromLinkId, Long toLinkId, List<String> args, bool
job.getConnectorId(Direction.TO)); job.getConnectorId(Direction.TO));
ResourceBundle driverConfigBundle = client.getDriverConfigBundle(); ResourceBundle driverConfigBundle = client.getDriverConfigBundle();
Status status = Status.FINE; Status status = Status.OK;
if (isInteractive) { if (isInteractive) {
printlnResource(Constants.RES_PROMPT_FILL_JOB_CONFIG); printlnResource(Constants.RES_PROMPT_FILL_JOB_CONFIG);

View File

@ -64,7 +64,7 @@ private Status createLink(long connectorId, List<String> args, boolean isInterac
ResourceBundle connectorConfigBundle = client.getConnectorConfigBundle(connectorId); ResourceBundle connectorConfigBundle = client.getConnectorConfigBundle(connectorId);
Status status = Status.FINE; Status status = Status.OK;
if (isInteractive) { if (isInteractive) {
printlnResource(Constants.RES_PROMPT_FILL_LINK_CONFIG); printlnResource(Constants.RES_PROMPT_FILL_LINK_CONFIG);

View File

@ -43,6 +43,6 @@ public DeleteJobFunction() {
@Override @Override
public Object executeFunction(CommandLine line, boolean isInteractive) { public Object executeFunction(CommandLine line, boolean isInteractive) {
client.deleteJob(getLong(line, Constants.OPT_JID)); client.deleteJob(getLong(line, Constants.OPT_JID));
return Status.FINE; return Status.OK;
} }
} }

View File

@ -42,6 +42,6 @@ public DeleteLinkFunction() {
@Override @Override
public Object executeFunction(CommandLine line, boolean isInteractive) { public Object executeFunction(CommandLine line, boolean isInteractive) {
client.deleteLink(getLong(line, Constants.OPT_LID)); client.deleteLink(getLong(line, Constants.OPT_LID));
return Status.FINE; return Status.OK;
} }
} }

View File

@ -51,6 +51,6 @@ public boolean validateArgs(CommandLine line) {
@Override @Override
public Object executeFunction(CommandLine line, boolean isInteractive) { public Object executeFunction(CommandLine line, boolean isInteractive) {
client.enableJob(getLong(line, Constants.OPT_JID), false); client.enableJob(getLong(line, Constants.OPT_JID), false);
return Status.FINE; return Status.OK;
} }
} }

View File

@ -42,6 +42,6 @@ public DisableLinkFunction() {
@Override @Override
public Object executeFunction(CommandLine line, boolean isInteractive) { public Object executeFunction(CommandLine line, boolean isInteractive) {
client.enableLink(getLong(line, Constants.OPT_LID), false); client.enableLink(getLong(line, Constants.OPT_LID), false);
return Status.FINE; return Status.OK;
} }
} }

View File

@ -43,6 +43,6 @@ public EnableJobFunction() {
@Override @Override
public Object executeFunction(CommandLine line, boolean isInteractive) { public Object executeFunction(CommandLine line, boolean isInteractive) {
client.enableJob(getLong(line, Constants.OPT_JID), true); client.enableJob(getLong(line, Constants.OPT_JID), true);
return Status.FINE; return Status.OK;
} }
} }

View File

@ -42,6 +42,6 @@ public EnableLinkFunction() {
@Override @Override
public Object executeFunction(CommandLine line, boolean isInteractive) { public Object executeFunction(CommandLine line, boolean isInteractive) {
client.enableLink(getLong(line, Constants.OPT_LID), true); client.enableLink(getLong(line, Constants.OPT_LID), true);
return Status.FINE; return Status.OK;
} }
} }

View File

@ -67,7 +67,7 @@ private Status handleOptionSetting(String name, String value) {
setVerbose(newValue); setVerbose(newValue);
printlnResource(Constants.RES_SET_VERBOSE_CHANGED, newValue); printlnResource(Constants.RES_SET_VERBOSE_CHANGED, newValue);
return Status.FINE; return Status.OK;
} }
if (name.equals(Constants.OPT_POLL_TIMEOUT)) { if (name.equals(Constants.OPT_POLL_TIMEOUT)) {
@ -82,7 +82,7 @@ private Status handleOptionSetting(String name, String value) {
setPollTimeout(newValue); setPollTimeout(newValue);
printlnResource(Constants.RES_SET_POLL_TIMEOUT_CHANGED, newValue); printlnResource(Constants.RES_SET_POLL_TIMEOUT_CHANGED, newValue);
return Status.FINE; return Status.OK;
} }
printlnResource(Constants.RES_SET_UNKNOWN_OPT_IGNORED, name); printlnResource(Constants.RES_SET_UNKNOWN_OPT_IGNORED, name);

View File

@ -81,6 +81,6 @@ public Object executeFunction(CommandLine line, boolean isInteractive) {
printlnResource(Constants.RES_SET_SERVER_SUCCESSFUL); printlnResource(Constants.RES_SET_SERVER_SUCCESSFUL);
return Status.FINE; return Status.OK;
} }
} }

View File

@ -23,8 +23,6 @@
import org.apache.commons.cli.CommandLine; import org.apache.commons.cli.CommandLine;
import org.apache.commons.cli.OptionBuilder; import org.apache.commons.cli.OptionBuilder;
import org.apache.sqoop.common.Direction;
import org.apache.sqoop.common.SupportedDirections;
import org.apache.sqoop.model.MConnector; import org.apache.sqoop.model.MConnector;
import org.apache.sqoop.shell.core.Constants; import org.apache.sqoop.shell.core.Constants;
import org.apache.sqoop.shell.utils.TableDisplayer; import org.apache.sqoop.shell.utils.TableDisplayer;
@ -58,7 +56,7 @@ public Object executeFunction(CommandLine line, boolean isInteractive) {
showSummary(); showSummary();
} }
return Status.FINE; return Status.OK;
} }
private void showSummary() { private void showSummary() {

View File

@ -45,7 +45,7 @@ public boolean validateArgs(CommandLine line) {
@Override @Override
public Object executeFunction(CommandLine line, boolean isInteractive) { public Object executeFunction(CommandLine line, boolean isInteractive) {
showDriver(); showDriver();
return Status.FINE; return Status.OK;
} }
private void showDriver() { private void showDriver() {

View File

@ -59,7 +59,7 @@ public Object executeFunction(CommandLine line, boolean isInteractive) {
showSummary(); showSummary();
} }
return Status.FINE; return Status.OK;
} }
private void showSummary() { private void showSummary() {

View File

@ -58,7 +58,7 @@ public Object executeFunction(CommandLine line, boolean isInteractive) {
showSummary(); showSummary();
} }
return Status.FINE; return Status.OK;
} }
private void showSummary() { private void showSummary() {

View File

@ -70,7 +70,7 @@ public Object executeFunction(CommandLine line, boolean isInteractive) {
return null; return null;
} }
return Status.FINE; return Status.OK;
} }
/** /**

View File

@ -75,7 +75,7 @@ public Object executeFunction(CommandLine line, boolean isInteractive) {
showServer(host, port, webapp, version); showServer(host, port, webapp, version);
} }
return Status.FINE; return Status.OK;
} }
private void showServer(boolean host, boolean port, boolean webapp, boolean version) { private void showServer(boolean host, boolean port, boolean webapp, boolean version) {

View File

@ -60,7 +60,7 @@ public Object executeFunction(CommandLine line, boolean isInteractive) {
} }
} }
return Status.FINE; return Status.OK;
} }
private void showSummary(Long jid) { private void showSummary(Long jid) {

View File

@ -79,7 +79,7 @@ public Object executeFunction(CommandLine line, boolean isInteractive) {
showVersion(server, client, restApi); showVersion(server, client, restApi);
} }
return Status.FINE; return Status.OK;
} }
private void showVersion(boolean server, boolean client, boolean restApi) { private void showVersion(boolean server, boolean client, boolean restApi) {

View File

@ -88,6 +88,6 @@ public void finished(MSubmission submission) {
return null; return null;
} }
return Status.FINE; return Status.OK;
} }
} }

View File

@ -54,6 +54,6 @@ public Object executeFunction(CommandLine line, boolean isInteractive) {
return null; return null;
} }
return Status.FINE; return Status.OK;
} }
} }

View File

@ -51,6 +51,6 @@ public Object executeFunction(CommandLine line, boolean isInteractive) {
return null; return null;
} }
return Status.FINE; return Status.OK;
} }
} }

View File

@ -70,7 +70,7 @@ private Status updateJob(Long jobId, List<String> args, boolean isInteractive) t
ResourceBundle driverConfigBundle = client.getDriverConfigBundle(); ResourceBundle driverConfigBundle = client.getDriverConfigBundle();
Status status = Status.FINE; Status status = Status.OK;
if (isInteractive) { if (isInteractive) {
printlnResource(Constants.RES_PROMPT_UPDATE_JOB_CONFIG); printlnResource(Constants.RES_PROMPT_UPDATE_JOB_CONFIG);

View File

@ -65,7 +65,7 @@ private Status updateLink(Long linkId, List<String> args, boolean isInteractive)
ResourceBundle connectorLinkConfigBundle = client.getConnectorConfigBundle(link.getConnectorId()); ResourceBundle connectorLinkConfigBundle = client.getConnectorConfigBundle(link.getConnectorId());
Status status = Status.FINE; Status status = Status.OK;
if (isInteractive) { if (isInteractive) {
printlnResource(Constants.RES_PROMPT_UPDATE_LINK_CONFIG); printlnResource(Constants.RES_PROMPT_UPDATE_LINK_CONFIG);

View File

@ -134,7 +134,7 @@ public static void displayConfig(List<MConfig> configs, ResourceBundle bundle) {
} }
/** /**
* Method prints the warning message of ACCEPTABLE status * Method prints the warning message of WARNING status
* @param entity - link or job instance * @param entity - link or job instance
*/ */
public static void displayConfigWarning(MAccountableEntity entity) { public static void displayConfigWarning(MAccountableEntity entity) {
@ -150,7 +150,7 @@ public static void displayConfigWarning(MAccountableEntity entity) {
configList.addAll(job.getJobConfig(Direction.TO).getConfigs()); configList.addAll(job.getJobConfig(Direction.TO).getConfigs());
} }
for(MConfig config : configList) { for(MConfig config : configList) {
if(config.getValidationStatus() == Status.ACCEPTABLE) { if(config.getValidationStatus() == Status.WARNING) {
if(showMessage) { if(showMessage) {
print("\n@|yellow %s|@\n", resourceString(Constants.RES_CONFIG_DISPLAYER_FORM_WARNING)); print("\n@|yellow %s|@\n", resourceString(Constants.RES_CONFIG_DISPLAYER_FORM_WARNING));
showMessage = false; showMessage = false;

View File

@ -820,7 +820,7 @@ static String getName(ConsoleReader reader, String name) throws IOException {
} }
/** /**
* Print validation message in cases that it's not in state "FINE" * Print validation message in cases that it's not in state "OK"
* *
* @param element Validated element * @param element Validated element
*/ */
@ -831,14 +831,14 @@ static void printValidationMessage(MValidatedElement element, boolean includeInp
for(Message message : element.getValidationMessages()) for(Message message : element.getValidationMessages())
switch (message.getStatus()) { switch (message.getStatus()) {
case UNACCEPTABLE: case ERROR:
if (includeInputPrefix) { if (includeInputPrefix) {
errorMessage(element, message.getMessage()); errorMessage(element, message.getMessage());
} else { } else {
errorMessage(message.getMessage()); errorMessage(message.getMessage());
} }
break; break;
case ACCEPTABLE: case WARNING:
if (includeInputPrefix) { if (includeInputPrefix) {
warningMessage(element, message.getMessage()); warningMessage(element, message.getMessage());
} else { } else {

View File

@ -219,7 +219,7 @@ protected void assertRowInCities(Object... values) {
* @param link * @param link
*/ */
protected void saveLink(MLink link) { protected void saveLink(MLink link) {
assertEquals(Status.FINE, getClient().saveLink(link)); assertEquals(Status.OK, getClient().saveLink(link));
assertNotSame(MPersistableEntity.PERSISTANCE_ID_DEFAULT, link.getPersistenceId()); assertNotSame(MPersistableEntity.PERSISTANCE_ID_DEFAULT, link.getPersistenceId());
} }
@ -231,7 +231,7 @@ protected void saveLink(MLink link) {
* @param job * @param job
*/ */
protected void saveJob(MJob job) { protected void saveJob(MJob job) {
assertEquals(Status.FINE, getClient().saveJob(job)); assertEquals(Status.OK, getClient().saveJob(job));
assertNotSame(MPersistableEntity.PERSISTANCE_ID_DEFAULT, job.getPersistenceId()); assertNotSame(MPersistableEntity.PERSISTANCE_ID_DEFAULT, job.getPersistenceId());
} }