+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ */
+public class ParaDirective extends Directive {
+
+ private int index = -1;
+ private String paraName = null;
+ private static boolean checkParaAssigned = true;
+
+ public static void setCheckParaAssigned(boolean checkParaAssigned) {
+ ParaDirective.checkParaAssigned = checkParaAssigned;
+ }
+
+ public void setExprList(ExprList exprList) {
+ if (exprList.length() == 0) {
+ throw new ParseException("The parameter of #para directive can not be blank", location);
+ }
+
+ if (exprList.length() == 1) {
+ Expr expr = exprList.getExpr(0);
+ if (expr instanceof Const && ((Const)expr).isInt()) {
+ index = ((Const)expr).getInt();
+ if (index < 0) {
+ throw new ParseException("The index of para array must greater than -1", location);
+ }
+ }
+ }
+
+ if (checkParaAssigned && exprList.getLastExpr() instanceof Id) {
+ Id id = (Id)exprList.getLastExpr();
+ paraName = id.getId();
+ }
+
+ this.exprList = exprList;
+ }
+
+ public void exec(Env env, Scope scope, Writer writer) {
+ TplPara tplPara = (TplPara)scope.get(TplKit.SQL_PARA_KEY);
+ if (tplPara == null) {
+ throw new TemplateException("#para directive invoked by getSqlPara(...) method only", location);
+ }
+
+ write(writer, "?");
+ if (index == -1) {
+ // #para(paraName) 中的 paraName 没有赋值时抛出异常
+ // issue: http://www.jfinal.com/feedback/1832
+ if (checkParaAssigned && paraName != null && !scope.exists(paraName)) {
+ throw new TemplateException("The parameter \""+ paraName +"\" must be assigned", location);
+ }
+
+ tplPara.addPara(exprList.eval(scope));
+ } else {
+ Object[] paras = (Object[])scope.get(TplKit.PARA_ARRAY_KEY);
+ if (paras == null) {
+ throw new TemplateException("The #para(" + index + ") directive must invoked by getSqlPara(String, Object...) method", location);
+ }
+ if (index >= paras.length) {
+ throw new TemplateException("The index of #para directive is out of bounds: " + index, location);
+ }
+ tplPara.addPara(paras[index]);
+ }
+ }
+}
+
+
+
diff --git a/src/main/java/com/jfinal/kit/tpl/TplDirective.java b/src/main/java/com/jfinal/kit/tpl/TplDirective.java
new file mode 100644
index 0000000..3a548c7
--- /dev/null
+++ b/src/main/java/com/jfinal/kit/tpl/TplDirective.java
@@ -0,0 +1,74 @@
+/**
+ * Copyright (c) 2011-2019, James Zhan 詹波 (jfinal@126.com).
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.jfinal.kit.tpl;
+
+import com.jfinal.kit.StrKit;
+import com.jfinal.kit.TplKit;
+import com.jfinal.template.Directive;
+import com.jfinal.template.Env;
+import com.jfinal.template.Template;
+import com.jfinal.template.expr.ast.Const;
+import com.jfinal.template.expr.ast.Expr;
+import com.jfinal.template.expr.ast.ExprList;
+import com.jfinal.template.io.Writer;
+import com.jfinal.template.stat.ParseException;
+import com.jfinal.template.stat.Scope;
+
+import java.util.Map;
+
+/**
+ * SqlDirective
+ */
+public class TplDirective extends Directive {
+
+ private String id;
+
+ public void setExprList(ExprList exprList) {
+ if (exprList.length() == 0) {
+ throw new ParseException("The parameter of #sql directive can not be blank", location);
+ }
+ if (exprList.length() > 1) {
+ throw new ParseException("Only one parameter allowed for #sql directive", location);
+ }
+ Expr expr = exprList.getExpr(0);
+ if (expr instanceof Const && ((Const)expr).isStr()) {
+ } else {
+ throw new ParseException("The parameter of #sql directive must be String", location);
+ }
+
+ this.id = ((Const)expr).getStr();
+ }
+
+ @SuppressWarnings("unchecked")
+ public void exec(Env env, Scope scope, Writer writer) {
+ String nameSpace = (String)scope.get(NameSpaceDirective.NAME_SPACE_KEY);
+ String key = StrKit.isBlank(nameSpace) ? id : nameSpace + "." + id;
+ Map sqlTemplateMap = (Map)scope.get(TplKit.SQL_TEMPLATE_MAP_KEY);
+ if (sqlTemplateMap.containsKey(key)) {
+ throw new ParseException("Sql already exists with key : " + key, location);
+ }
+
+ sqlTemplateMap.put(key, new Template(env, stat));
+ }
+
+ public boolean hasEnd() {
+ return true;
+ }
+}
+
+
+
diff --git a/src/main/java/com/jfinal/kit/tpl/TplPara.java b/src/main/java/com/jfinal/kit/tpl/TplPara.java
new file mode 100644
index 0000000..dbced35
--- /dev/null
+++ b/src/main/java/com/jfinal/kit/tpl/TplPara.java
@@ -0,0 +1,71 @@
+/**
+ * Copyright (c) 2011-2019, James Zhan 詹波 (jfinal@126.com).
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.jfinal.kit.tpl;
+
+import java.io.Serializable;
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * SqlPara
+ * 封装查询使用的 sql 与参数，主要用于 getSqlPara(...) 返回值
+ */
+public class TplPara implements Serializable {
+
+ private static final long serialVersionUID = -8586448059592782381L;
+
+ String sql;
+ List