Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[CUBRIDQA-1203] support '--+ server-message on' directive also in CCI tests #671

Merged
merged 9 commits into from
Jan 15, 2024
Merged

[CUBRIDQA-1203] support '--+ server-message on' directive also in CCI tests #671

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
9 commits
Select commit Hold shift + click to select a range
a1315e7
removed an unused inner class MutiSqlEx
hyunikn Dec 15, 2023
c9169a9
minor: replace strncasecmp with startswithCI
hyunikn Dec 19, 2023
e760548
implement '--+ server-message on' directive
hyunikn Dec 19, 2023
306c880
code style
hyunikn Dec 19, 2023
925a0c3
minor bugfix
hyunikn Dec 20, 2023
2f97d2e
append a newline character also to the last line of a statement in or…
hyunikn Dec 21, 2023
d5d6023
send commit, rollback, savepoint statement to the server rather than …
hyunikn Dec 21, 2023
94f0e8c
code style
hyunikn Dec 27, 2023
b10212f
restored execution of COMMIT, ROLLBACK, and SAVEPOINT by CCI API
hyunikn Jan 9, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
230 changes: 1 addition & 229 deletions CTP/sql/src/com/navercorp/cubridqa/cqt/console/bo/ConsoleBO.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -1137,7 +1137,7 @@ private String executeSqlFile(Test test, CaseResult caseResult) {
test.setServerMessage("on");
// TODO: DBMS_OUTPUT.enable ()
Sql enableSql =
new Sql(connId, "CALL enable(20000)", null, true); // TODO: set
new Sql(connId, "CALL enable(50000)", null, true); // TODO: set
// size of
// enable
dao.execute(conn, enableSql, false);
Expand Down Expand Up @@ -1421,234 +1421,6 @@ public ProcessMonitor getProcessMonitor() {
return processMonitor;
}

/**
* this inner class created by anson cheung,it used for execute sql muti-thread
*
* @author Administrator
*/
class MutiSqlEx extends Thread {
private Test test;
private int index;

private CaseResult caseResult;

public void setTest(Test test) {
this.test = test;
}

public void setCaseResult(CaseResult caseResult) {
this.caseResult = caseResult;
}

public CaseResult getCaseResult() {
return caseResult;
}

private ConsoleBO bo;

public void setBo(ConsoleBO bo) {
this.bo = bo;
}

public MutiSqlEx(String name) {
super(name);
}

@Override
public void run() {
List<Connection> ConnList = new ArrayList<Connection>();
if (test == null
|| caseResult == null
|| processMonitor.getCurrentstate() == processMonitor.Status_Stoping
|| processMonitor.getCurrentstate() == processMonitor.Status_Stoping) {
return;
}
String caseFile = caseResult.getCaseFile();
StringBuilder result = new StringBuilder();
List<Sql> sqlList =
SQLParser.parseSqlFile(caseFile, test.getCodeset(), test.isNeedDebugHint());

String dbId = test.getDbId();
String connId = test.getConnId();
CubridConnection cubridConnection =
dao.getCubridConnection(dbId, connId, test.getType());

// check if CQT need check server status when start each file test
// executing
if (test.isNeedCheckServerStatus()) {
checkServerStatus(cubridConnection);
}

// set db charset for test
resetConnection(cubridConnection, test);

if (sqlList == null) {
return;
}
try {
test.setDbId(test.getDbId(caseFile));
long startTime = System.currentTimeMillis();
for (int k = 0; k < sqlList.size(); k++) {
if (processMonitor.getCurrentstate() == processMonitor.Status_Stoping
|| processMonitor.getCurrentstate() == processMonitor.Status_Stoping) {
return;
}
Sql sql = (Sql) sqlList.get(k);
if (sql == null) {
continue;
}

String script = sql.getScript();
// String dbId = test.getDbId();
// String connId = test.getConnId();
String ThreadConnId = connId;
String thisConnId = sql.getConnId();
if (!thisConnId.equals("") && !thisConnId.equals(connId)) {
ThreadConnId = thisConnId;
cubridConnection =
dao.getCubridConnection(dbId, ThreadConnId, index, test.getType());
resetConnection(cubridConnection, test);
}

cubridConnection.isAvlible();
Connection conn = cubridConnection.getConn();
ConnList.add(conn);
boolean isOn = isPropOn(TestUtil.AUTOCOMMIT, script);
boolean isOff = isPropOff(TestUtil.AUTOCOMMIT, script);
boolean isHoldCasOn = isPropOn(TestUtil.HOLDCAS, script);
boolean isHoldCasOff = isPropOff(TestUtil.HOLDCAS, script);
boolean isServerMessageOn = isPropOn(TestUtil.SERVER_MESSAGE, script);
boolean isServerMessageOff = isPropOff(TestUtil.SERVER_MESSAGE, script);

if (isOn) {
conn.setAutoCommit(isOn);
String message = "@" + test.getConnId() + ": autocommit " + isOn;
bo.onMessage("[THREAD:" + index + "]" + message);
} else if (isOff) {
conn.setAutoCommit(!isOff);
String message = "@" + test.getConnId() + ": autocommit " + !isOff;
bo.onMessage("[THREAD:" + index + "]" + message);
} else if (isHoldCasOn) {
try {
String message = "@" + test.getConnId() + ": hold cas " + isHoldCasOn;

Method method =
conn.getClass()
.getMethod("setCASChangeMode", new Class[] {int.class});
method.invoke(
conn, new Object[] {CUBRIDConnection.CAS_CHANGE_MODE_KEEP});

bo.onMessage("--- hold cas -- " + isHoldCasOn);
} catch (Exception e) {
String message =
"Exception: the current version can't support hold cas!";
bo.onMessage(message);
}
} else if (isHoldCasOff) {
try {
String message = "@" + test.getConnId() + ": hold cas " + isHoldCasOff;
Method method =
conn.getClass()
.getMethod("setCASChangeMode", new Class[] {int.class});
method.invoke(
conn, new Object[] {CUBRIDConnection.CAS_CHANGE_MODE_AUTO});
bo.onMessage("--- hold cas -- " + isHoldCasOff);
} catch (Exception e) {
String message =
"Exception: the current version can't support hold cas!";
bo.onMessage(message);
}
} else if (isServerMessageOn) {
try {
String message =
"@"
+ test.getConnId()
+ ": server message "
+ isServerMessageOn;
bo.onMessage(message);

Sql enableSql =
new Sql(
connId,
"CALL DBMS_OUTPUT.enable(20000)",
null,
true); // TODO: set
// size of
// enable
dao.execute(conn, enableSql, false);
} catch (Exception e) {
String message =
"Exception: the current version can't support DBMS_OUTPUT!";
bo.onMessage(message);
}
} else if (isServerMessageOff) {
try {
String message =
"@"
+ test.getConnId()
+ ": server message "
+ isServerMessageOff;
bo.onMessage(message);
Sql disableSql =
new Sql(connId, "CALL DBMS_OUTPUT.disable()", null, true);
dao.execute(conn, disableSql, false);
} catch (Exception e) {
String message =
"Exception: the current version can't support DBMS_OUTPUT!";
bo.onMessage(message);
}
} else {
// System.out.println("--- use default autocommit -- " +
// conn.getAutoCommit());
String message =
"@"
+ test.getDbId()
+ "/"
+ test.getConnId()
+ ":"
+ sql.getScript();
bo.onMessage("[THREAD:" + index + "]" + message);

// System.out.println ("script = " + sql.getScript());

dao.execute(conn, sql, caseResult.isPrintQueryPlan());
result.append("===================================================");
result.append(System.getProperty("line.separator"));
result.append(sql.getResult());
}

cubridConnection.free();
}
long totalTime = System.currentTimeMillis() - startTime;
caseResult.setTotalTime(totalTime);

} catch (Exception e) {

result.append(e.getMessage() + System.getProperty("line.separator"));

e.printStackTrace();
} finally {
caseResult.setResult(result.toString());
caseResult.setSiteRunTimes(test.getSiteRunTimes());
}
for (Connection conn : ConnList) {
try {
conn.commit();
} catch (SQLException e) {
e.printStackTrace();
}
}
}

public int getIndex() {
return index;
}

public void setIndex(int index) {
this.index = index;
}
}

public Test getTest() {
return test;
}
Expand Down
Loading
Loading