Taoyouce
/
examples
forked from opengaussexamples/examples
0
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix some bugs

This commit is contained in:
XudongXie 2024-09-20 15:08:51 +08:00
parent bfd142e34f
commit 4a25a62b72
6 changed files with 90 additions and 119 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

48
sqlTranslate/.idea/workspace.xml
View File

@ -4,11 +4,13 @@
<option name="autoReloadType" value="SELECTIVE" />
</component>
<component name="ChangeListManager">
<list default="true" id="d8d12963-4777-48e3-9669-309cf5e41d60" name="更改" comment="add unit test">
<change afterPath="$PROJECT_DIR$/src/test/java/testJoin.java" afterDir="false" />
<list default="true" id="d8d12963-4777-48e3-9669-309cf5e41d60" name="更改" comment="fix some bugs">
<change afterPath="$PROJECT_DIR$/src/test/java/testCaseWhen.java" afterDir="false" />
<change beforePath="$PROJECT_DIR$/.idea/workspace.xml" beforeDir="false" afterPath="$PROJECT_DIR$/.idea/workspace.xml" afterDir="false" />
<change beforePath="$PROJECT_DIR$/src/main/java/Main.java" beforeDir="false" afterPath="$PROJECT_DIR$/src/main/java/Main.java" afterDir="false" />
<change beforePath="$PROJECT_DIR$/src/main/java/lexer/OracleLexer.java" beforeDir="false" afterPath="$PROJECT_DIR$/src/main/java/lexer/OracleLexer.java" afterDir="false" />
<change beforePath="$PROJECT_DIR$/src/main/java/document/Select statement in Oracle" beforeDir="false" afterPath="$PROJECT_DIR$/src/main/java/document/Select statement in Oracle" afterDir="false" />
<change beforePath="$PROJECT_DIR$/src/main/java/document/Todolist" beforeDir="false" afterPath="$PROJECT_DIR$/src/main/java/document/Todolist" afterDir="false" />
<change beforePath="$PROJECT_DIR$/src/test/java/testSelect.java" beforeDir="false" afterPath="$PROJECT_DIR$/src/test/java/testSelect.java" afterDir="false" />
</list>
<option name="SHOW_DIALOG" value="false" />
<option name="HIGHLIGHT_CONFLICTS" value="true" />
@ -46,6 +48,7 @@
"Application.Main.executor": "Run",
"JUnit.testAlterTable.executor": "Run",
"JUnit.testAlterTable.testAlterTable.executor": "Run",
"JUnit.testCaseWhen.test.executor": "Run",
"JUnit.testCommitRollbackExec.test.executor": "Run",
"JUnit.testCreateTable.executor": "Run",
"JUnit.testCreateTable.test.executor": "Run",
@ -60,6 +63,7 @@
"JUnit.testLoop.test.executor": "Run",
"JUnit.testPL.executor": "Run",
"JUnit.testProcedure.test.executor": "Run",
"JUnit.testSelect.executor": "Run",
"JUnit.testSelect.test.executor": "Run",
"JUnit.testTrigger.executor": "Run",
"JUnit.testUpdate.executor": "Run",
@ -75,7 +79,7 @@
"settings.editor.selected.configurable": "preferences.pluginManager"
}
}]]></component>
<component name="RunManager" selected="JUnit.testProcedure.test">
<component name="RunManager" selected="JUnit.testCaseWhen.test">
<configuration name="testAlterTable" type="JUnit" factoryName="JUnit" temporary="true" nameIsGenerated="true">
<module name="sqlTranslate" />
<option name="PACKAGE_NAME" value="" />
@ -85,6 +89,16 @@
<option name="Make" enabled="true" />
</method>
</configuration>
<configuration name="testCaseWhen.test" type="JUnit" factoryName="JUnit" temporary="true" nameIsGenerated="true">
<module name="sqlTranslate" />
<option name="PACKAGE_NAME" value="" />
<option name="MAIN_CLASS_NAME" value="testCaseWhen" />
<option name="METHOD_NAME" value="test" />
<option name="TEST_OBJECT" value="method" />
<method v="2">
<option name="Make" enabled="true" />
</method>
</configuration>
<configuration name="testJoin" type="JUnit" factoryName="JUnit" temporary="true" nameIsGenerated="true">
<module name="sqlTranslate" />
<option name="PACKAGE_NAME" value="" />
@ -104,20 +118,10 @@
<option name="Make" enabled="true" />
</method>
</configuration>
<configuration name="testSelect.test" type="JUnit" factoryName="JUnit" temporary="true" nameIsGenerated="true">
<configuration name="testSelect" type="JUnit" factoryName="JUnit" temporary="true" nameIsGenerated="true">
<module name="sqlTranslate" />
<option name="PACKAGE_NAME" value="" />
<option name="MAIN_CLASS_NAME" value="testSelect" />
<option name="METHOD_NAME" value="test" />
<option name="TEST_OBJECT" value="method" />
<method v="2">
<option name="Make" enabled="true" />
</method>
</configuration>
<configuration name="testUpdate" type="JUnit" factoryName="JUnit" temporary="true" nameIsGenerated="true">
<module name="sqlTranslate" />
<option name="PACKAGE_NAME" value="" />
<option name="MAIN_CLASS_NAME" value="testUpdate" />
<option name="TEST_OBJECT" value="class" />
<method v="2">
<option name="Make" enabled="true" />
@ -125,18 +129,18 @@
</configuration>
<list>
<item itemvalue="JUnit.testAlterTable" />
<item itemvalue="JUnit.testCaseWhen.test" />
<item itemvalue="JUnit.testJoin" />
<item itemvalue="JUnit.testProcedure.test" />
<item itemvalue="JUnit.testSelect.test" />
<item itemvalue="JUnit.testUpdate" />
<item itemvalue="JUnit.testSelect" />
</list>
<recent_temporary>
<list>
<item itemvalue="JUnit.testCaseWhen.test" />
<item itemvalue="JUnit.testSelect" />
<item itemvalue="JUnit.testProcedure.test" />
<item itemvalue="JUnit.testAlterTable" />
<item itemvalue="JUnit.testJoin" />
<item itemvalue="JUnit.testSelect.test" />
<item itemvalue="JUnit.testUpdate" />
</list>
</recent_temporary>
</component>
@ -492,7 +496,7 @@
<option name="project" value="LOCAL" />
<updated>1726633703475</updated>
</task>
<option name="localTasksCounter" value="101" />
<option name="localTasksCounter" value="102" />
<servers />
</component>
<component name="Vcs.Log.Tabs.Properties">
@ -507,7 +511,6 @@
</option>
</component>
<component name="VcsManagerConfiguration">
<MESSAGE value="add if elseif else endif document" />
<MESSAGE value="add if elseif else endif ast classes" />
<MESSAGE value="add IF ELSIF" />
<MESSAGE value="add Loop document" />
@ -532,7 +535,8 @@
<MESSAGE value="add pl/sql" />
<MESSAGE value="revise" />
<MESSAGE value="add unit test" />
<option name="LAST_COMMIT_MESSAGE" value="add unit test" />
<MESSAGE value="fix some bugs" />
<option name="LAST_COMMIT_MESSAGE" value="fix some bugs" />
</component>
<component name="XDebuggerManager">
<watches-manager>

94
sqlTranslate/src/main/java/Main.java
View File

@ -7,101 +7,9 @@ import parser.OracleParser;
public class Main {
public static void main(String[] args) {
// String sql = "CREATE TABLE employees (\n" +
// " employee_id NUMBER PRIMARY KEY,\n" +
// " first_name VARCHAR2(20) Check(first_name > '221'),\n" +
// " last_name VARCHAR2(25) Check (last_name != '12813@163.com'),\n" +
// " email VARCHAR2(25),\n" +
// " hire_date DATE,\n" +
// " CONSTRAINT chk_example CHECK (employee_id > 0)" +
// ");";
// String sql = "INSERT INTO employees (first_name, last_name, email) VALUES ('Jane', 'Smith', 'janesm@example.com');";
// String sql = "DROP TABLE employees CASCADE CONSTRAINTS;";
String sql = "SELECT e.first_name, d.department_name FROM employees e JOIN departments d Using e.department_id = d.department_id;";
// String sql = "employees e JOIN departments d ON e.department_id = d.department_id;";
// String sql = "UPDATE employees e\n" +
// "JOIN departments d using e.department_id = d.department_id\n" +
// "SET e.salary = e.salary * 1.10,\n" +
// " d.budget = d.budget * 1.10\n" +
// "WHERE d.department_name = 'Sales';";
// String sql = "DELETE FROM employees e\n" +
// "WHERE e.department_id IN (\n" +
// " SELECT d.department_id\n" +
// " FROM departments d\n" +
// " WHERE d.department_name = 'Sales'\n" +
// ");";
// String sql = "ALTER TABLE employees ADD email VARCHAR2(100) Check (email != '12813@163.com');";
// String sql = "CASE WHEN column2 > 0 THEN 'Positive' ELSE 'Non-positive' END";
// String sql = "CREATE OR REPLACE VIEW emp_dept_info AS SELECT e.first_name, e.last_name, d.department_name FROM employees e JOIN departments d Using e.department_id = d.department_id;";
// String sql = "IF v_salary >= 100000 THEN\n" +
// " v_bonus := v_salary * 0.1;\n" +
// " ELSIF v_salary >= 50000 THEN\n" +
// " v_bonus := v_salary * 0.08;\n" +
// " ELSIF v_salary >= 30000 THEN\n" +
// " v_bonus := v_salary * 0.05;\n" +
// " ELSE\n" +
// " v_bonus := v_salary * 0.03;\n" +
// " END IF;";
// String sql = "LOOP\n" +
// " DBMS_OUTPUT.PUT_LINE(v_counter);\n" +
// " Continue;\n" +
// " v_counter := v_counter + 1;\n" +
// " EXIT WHEN v_counter > 10;\n" +
// " END LOOP;";
// String sql = "EXCEPTION\n" +
// " WHEN e_custom_exception THEN\n" +
// " DBMS_OUTPUT.PUT_LINE('Caught an exception: Custom exception raised');\n" +
// " WHEN ZERO_DIVIDE THEN\n" +
// " DBMS_OUTPUT.PUT_LINE('Caught an exception: Division by zero');\n" +
// " WHEN INVALID_NUMBER THEN\n" +
// " DBMS_OUTPUT.PUT_LINE('Caught an exception: Invalid number');\n" +
// " WHEN OTHERS THEN\n" +
// " DBMS_OUTPUT.PUT_LINE('Caught an exception: ' || SQLERRM);";
// String sql = "CREATE OR REPLACE PROCEDURE update_salary (\n" +
// " employee_id IN NUMBER,\n" +
// " new_salary IN OUT NUMBER\n" +
// " ) IS\n" +
// " v_employee NUMBER;\n" +
// " BEGIN\n" +
// " SELECT * INTO v_employee FROM employees WHERE employee_id = employee_id;\n" +
// "\n" +
// " IF new_salary < 3000 THEN\n" +
// " new_salary := new_salary * 1.1;\n" +
// " ELSE\n" +
// " new_salary := new_salary * 1.05;\n" +
// " END IF;\n" +
// "\n" +
// " UPDATE employees SET salary = new_salary WHERE employee_id = employee_id;\n" +
// " COMMIT;\n" +
// "\n" +
// " DBMS_OUTPUT.PUT_LINE('Updated Salary: ' || new_salary);\n" +
// " EXCEPTION\n" +
// " WHEN NO_DATA_FOUND THEN\n" +
// " DBMS_OUTPUT.PUT_LINE('Employee not found.');\n" +
// " WHEN TOO_MANY_ROWS THEN\n" +
// " DBMS_OUTPUT.PUT_LINE('Multiple employees found.');\n" +
// " WHEN OTHERS THEN\n" +
// " DBMS_OUTPUT.PUT_LINE('An error occurred: ' || SQLERRM);\n" +
// " END update_salary;\n";
// String sql = "CREATE OR REPLACE FUNCTION string_length (\n" +
// " input_string VARCHAR2\n" +
// ") RETURN NUMBER IS\n" +
// "BEGIN\n" +
// " RETURN LENGTH(input_string);\n" +
// "END;\n";
// String sql = "CREATE OR REPLACE TRIGGER log_insert\n" +
// " BEFORE INSERT ON employees\n" +
// " FOR EACH ROW\n" +
// " BEGIN\n" +
// " INSERT INTO audit_log (action, employee_id) VALUES ('INSERT', :NEW.id);\n" +
// " END;";
// String sql = "DECLARE\n" +
// " v_name Varchar2(20);\n" +
// " v_salary employees.salary%TYPE;\n" +
// " BEGIN\n" +
// " SELECT name, salary INTO v_name, v_salary FROM employees WHERE employee_id = 100;\n" +
// " DBMS_OUTPUT.PUT_LINE('Name: ' || v_name || ', Salary: ' || v_salary);\n" +
// " END;";
//
OracleLexer lexer = new OracleLexer(sql);
lexer.printTokens();
OracleParser parser = new OracleParser(lexer);

3
sqlTranslate/src/main/java/document/Select statement in Oracle
View File

@ -5,8 +5,7 @@ select_option = GROUP BY | ORDER BY | HAVING
function = COUNT() | SUM() | AVG() | MAX() | MIN()
example:
SELECT * FROM employees;
SELECT employee_id, first_name, last_name FROM employees;
SELECT * FROM employees Union SELECT employee_id, first_name, last_name FROM employees;
SELECT * FROM employees WHERE department_id = 10;
SELECT * FROM employees ORDER BY hire_date DESC;
SELECT COUNT(*), AVG(salary) FROM employees;

16
sqlTranslate/src/main/java/generator/OpenGaussGenerator.java
View File

@ -8,6 +8,7 @@ import parser.ast.ASTNode;
import parser.ast.alterTable.AlterAddColumnNode;
import parser.ast.alterTable.AlterModifyColumnNode;
import parser.ast.alterTable.AlterNode;
import parser.ast.caseWhen.CaseConditionNode;
import parser.ast.createTable.ColumnNode;
import parser.ast.createTable.CreateTabNode;
import exception.GenerateFailedException;
@ -102,6 +103,9 @@ public class OpenGaussGenerator {
else if (node instanceof IFConditionNode) {
return GenIfElseSQL(node);
}
else if (node instanceof CaseConditionNode) {
return GenCaseWhenSQL(node);
}
else {
try {
throw new GenerateFailedException("Root node:" + node.getClass() + "(Unsupported node type!)");
@ -141,6 +145,11 @@ public class OpenGaussGenerator {
return node.toQueryString();
}
private String GenCaseWhenSQL(ASTNode node) {
visitCaseWhen(node);
return node.toQueryString();
}
private String GenUpdateSQL(ASTNode node) {
visitUpdate(node);
// System.out.println(node.getASTString());
@ -235,6 +244,13 @@ public class OpenGaussGenerator {
}
}
private void visitCaseWhen(ASTNode node) {
for (ASTNode child : node.getChildren()) {
visitCaseWhen(child);
}
}
private void visitLoop(ASTNode node) {
if (CommonConfig.getSourceDB().equalsIgnoreCase("ORACLE-19C")
&& CommonConfig.getTargetDB().equalsIgnoreCase("OPENGAUSS-3.0.0")) {

45
sqlTranslate/src/test/java/testCaseWhen.java Normal file
View File

@ -0,0 +1,45 @@
import config.CommonConfig;
import generator.OpenGaussGenerator;
import lexer.OracleLexer;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
import parser.OracleParser;
import parser.ast.ASTNode;
import java.util.ArrayList;
import java.util.List;
public class testCaseWhen {
List<String> testSQL = new ArrayList<>();
@BeforeEach
public void loadData()
{
testSQL.add("CASE WHEN column2 > 0 THEN 'Positive' ELSE 'Non-positive' END");
System.out.println("===== test of CaseWhen =====");
System.out.println("The source DBMS is: " + CommonConfig.getSourceDB());
System.out.println("The target DBMS is: " + CommonConfig.getTargetDB());
System.out.println();
}
@Test
public void test()
{
int num = 1;
for (String sql : testSQL) {
System.out.println("===== test the SQL" + num++ + " =====");
System.out.println("Input SQL: " + sql);
OracleLexer lexer = new OracleLexer(sql);
lexer.printTokens();
ASTNode root = OracleParser.parseCaseWhen(lexer.getTokens());
System.out.println("The AST of the input SQL: ");
System.out.println(root.getASTString());
System.out.println("The query String of the AST parsed from the input SQL: ");
System.out.println(root.toQueryString());
OpenGaussGenerator generator = new OpenGaussGenerator(root);
System.out.println("The converted query String: ");
System.out.println(generator.generate());
System.out.println();
}
}
}

3
sqlTranslate/src/test/java/testSelect.java
View File

@ -14,8 +14,7 @@ public class testSelect {
@BeforeEach
public void loadData()
{
testSQL.add("SELECT * FROM employees;");
testSQL.add("SELECT employee_id, first_name, last_name FROM employees;");
testSQL.add("SELECT * FROM employees Union SELECT employee_id, first_name, last_name FROM employees;");
testSQL.add("SELECT * FROM employees WHERE department_id = 10;");
testSQL.add("SELECT * FROM employees ORDER BY hire_date DESC;");
testSQL.add("SELECT COUNT(*), AVG(salary) FROM employees;");