import net.sf.jsqlparser.schema.Table;
import net.sf.jsqlparser.statement.alter.Alter;
import net.sf.jsqlparser.statement.alter.AlterExpression;
import net.sf.jsqlparser.statement.alter.AlterOperation;
import net.sf.jsqlparser.statement.create.table.ColDataType;
import java.util.Collections;
public class AlterTableDemo {
public static void main(String[] args)throws Exception {
Alter alter = new Alter();
alter.setTable(new Table("t_one"));
ColDataType varchar = new ColDataType("VARCHAR");
varchar.setArgumentsStringList(Collections.singletonList("128"));
AlterExpression.ColumnDataType name = new AlterExpression.ColumnDataType("name", false, varchar, Collections.singletonList("COMMENT '道号'"));
AlterExpression alterExpression = new AlterExpression();
alterExpression.setOperation(AlterOperation.MODIFY);
alterExpression.addColDataType(name);
alter.addAlterExpression(alterExpression);
ColDataType anInt = new ColDataType("INT");
anInt.setArgumentsStringList(Collections.singletonList("10"));
AlterExpression.ColumnDataType age = new AlterExpression.ColumnDataType("age", false, anInt, Collections.singletonList("COMMENT '仙龄'"));
AlterExpression ageAlterexpression = new AlterExpression();
ageAlterexpression.setOperation(AlterOperation.MODIFY);
ageAlterexpression.addColDataType(age);
alter.addAlterExpression(ageAlterexpression);
System.out.println(alter);
ALTER TABLE t_one MODIFY name VARCHAR (128) COMMENT '道号', MODIFY age INT (10) COMMENT '仙龄'
import net.sf.jsqlparser.schema.Table;
import net.sf.jsqlparser.statement.alter.Alter;
import net.sf.jsqlparser.statement.alter.AlterExpression;
import net.sf.jsqlparser.statement.alter.AlterOperation;
import net.sf.jsqlparser.statement.create.table.ColDataType;
import java.util.Collections;
public class AddColumnDemo {
public static void main(String[] args) {
Alter alter = new Alter();
alter.setTable(new Table("t_one"));
AlterExpression alterExpression = new AlterExpression();
alterExpression.setOperation(AlterOperation.ADD);
ColDataType bigint = new ColDataType("BIGINT");
bigint.setArgumentsStringList(Collections.singletonList("20"));
AlterExpression.ColumnDataType fightingCapacity = new AlterExpression.ColumnDataType("fighting_capacity", false, bigint, Collections.singletonList("COMMENT '战力'"));
alterExpression.addColDataType(fightingCapacity);
alter.addAlterExpression(alterExpression);
System.out.println(alter);
ALTER TABLE t_one ADD fighting_capacity BIGINT (20) COMMENT '战力'
import net.sf.jsqlparser.schema.Table;
import net.sf.jsqlparser.statement.alter.Alter;
import net.sf.jsqlparser.statement.alter.AlterExpression;
import net.sf.jsqlparser.statement.alter.AlterOperation;
public class DropColumnDemo {
public static void main(String[] args)throws Exception {
Alter alter = new Alter();
alter.setTable(new Table("t_one"));
AlterExpression alterExpression = new AlterExpression();
alterExpression.setOperation(AlterOperation.DROP);
alterExpression.setColumnName("fighting_capacity");
alter.addAlterExpression(alterExpression);
System.out.println(alter);
ALTER TABLE t_one DROP fighting_capacity
/ 修改姓名 ColDataType varchar = new ColDataType("VARCHAR");AlterExpression . ColumnDataType name = new AlterExpression . ColumnDataType("name" , false , varchar , Collections . singletonList("COMMENT '道号'"));
源码地址 https://github.com/JSQLParser/JSqlParser源码分析ColDataType 列数据类型有2个属性:
String dataType 标识数据类型
List argumentsStringList 类型参数
例如 `user_num` VARCHAR(50) NOT NULL COMMENT '用户编号'
中的 VARCHAR(50) NOT NUL
String xxx = " AUTO_INCREMENT ";
CreateTable createTable = (CreateTable) CCJSqlParserUtil.parse(" CREATE TABLE `t_student` (\n" +
" `student_id` int(10) unsigned NO
jsqlparser描述:
JSqlParser 解析 SQL 语句并将其转换为 Java 类的层次结构。基本上的sql关键字和函数都可以被jsqlparser解析成对象层层包装。
实现的功能:
基础sql查询,条件查询,字段和表得别名,排序,分组,聚合,case when,基本上都是有得。
我的使用场景:
将一个表和字段不是数据库直接查询的表字段,进行通过jsqlparser来转换成elasticsearch中存储的表和字段进行到openlokeng中进行查询
界面输入:
openlookeng 执行:
jsqlparser可以用来识别SQL语句中的函数。具体来说,可以使用以下步骤来实现:
1. 创建一个实现ExpressionVisitor接口的类,用于访问SQL语句中的各种表达式。
2. 使用CCJSqlParserManager类中的parse方法来解析SQL语句,将其转换为Statement对象。
3. 使用Statement对象中的accept方法,将上面创建的ExpressionVisitor对象传递给它,然后调用该方法以开始遍历SQL语句的各个部分。
4. 在ExpressionVisitor类中覆盖visit方法,以处理不同类型的表达式,包括函数。在visit方法中,您可以检查当前表达式是否是函数,并从中提取所需的信息。
下面是一个简单的示例,演示如何在SQL语句中识别函数:
```java
import java.io.StringReader;
import net.sf.jsqlparser.expression.Function;
import net.sf.jsqlparser.expression.ExpressionVisitorAdapter;
import net.sf.jsqlparser.JSQLParserException;
import net.sf.jsqlparser.parser.CCJSqlParserManager;
import net.sf.jsqlparser.statement.Statement;
import net.sf.jsqlparser.statement.select.Select;
import net.sf.jsqlparser.statement.select.PlainSelect;
public class SqlFunctionParser {
public static void main(String[] args) throws JSQLParserException {
String sql = "SELECT COUNT(*) FROM mytable WHERE myfunc(col1) > 5";
CCJSqlParserManager parserManager = new CCJSqlParserManager();
Statement statement = parserManager.parse(new StringReader(sql));
Select select = (Select) statement;
PlainSelect plainSelect = (PlainSelect) select.getSelectBody();
plainSelect.getWhere().accept(new ExpressionVisitorAdapter() {
@Override
public void visit(Function function) {
System.out.println("Found function: " + function.getName());
System.out.println("Function parameters: " + function.getParameters());
在上面的示例中,我们解析了一个包含函数的SQL语句,并使用ExpressionVisitorAdapter类来访问WHERE子句中的表达式。在visit方法中,我们检查每个表达式是否是函数,并打印出其名称和参数。