插件读写数据库示例

.gitignore

@@ -0,0 +1,5 @@
+*.iml
+.idea/
+lib/report/*.jar
+.classpath
+.DS_Store

build.xml

@@ -0,0 +1,130 @@
+<?xml version="1.0" encoding="UTF-8" standalone="no"?>
+<project basedir="." default="jar" name="plugin">
+    <!-- JDK路径，根据自己机器上实际位置修改-->
+    <property name="jdk.home" value="/Library/Java/JavaVirtualMachines/jdk1.8/Contents/Home"/>
+
+    <property name="libs" value="${basedir}/lib"/>
+    <property name="publicLibs" value=""/>
+    <property name="reportLibs" value="${basedir}/../webroot/WEB-INF/lib"/>
+    <property name="destLoc" value="."/>
+    <property name="classes" value="classes"/>
+    <xmlproperty file="${basedir}/plugin.xml"/>
+    <property name="current-version" value="${plugin.version}"/>
+
+    <!-- 插件版本-->
+    <property name="plugin-version" value="${current-version}"/>
+    <!-- 插件名字-->
+    <property name="plugin-name" value="db-access"/>
+    <property name="plugin-jar" value="fr-plugin-${plugin-name}-${plugin-version}.jar"/>
+
+    <target name="prepare">
+        <delete dir="${classes}"/>
+        <delete dir="fr-plugin-${plugin-name}-${plugin-version}"/>
+        <xmlproperty file="${basedir}/plugin.xml"/>
+        <delete dir="${destLoc}/${plugin.name}"/>
+    </target>
+    <path id="compile.classpath">
+        <fileset dir="${libs}">
+            <include name="**/*.jar"/>
+        </fileset>
+        <fileset dir="${publicLibs}">
+            <include name="**/*.jar"/>
+        </fileset>
+        <fileset dir="${reportLibs}">
+            <include name="**/*.jar"/>
+        </fileset>
+    </path>
+    <patternset id="resources4Jar">
+        <exclude name="**/.settings/**"/>
+        <exclude name=".classpath"/>
+        <exclude name=".project"/>
+
+        <exclude name="**/*.java"/>
+        <exclude name="**/*.db"/>
+        <exclude name="**/*.g"/>
+        <exclude name="**/package.html"/>
+    </patternset>
+    <target name="copy_resources">
+        <echo message="从${resources_from}拷贝图片,JS,CSS等资源文件"/>
+        <delete dir="tmp"/>
+        <copy todir="tmp">
+            <fileset dir="${resources_from}/src/main/resources">
+                <patternset refid="resources4Jar"/>
+            </fileset>
+        </copy>
+        <copy todir="${classes}">
+            <fileset dir="tmp"/>
+        </copy>
+        <delete dir="tmp"/>
+    </target>
+    <target name="compile_javas">
+        <echo message="编译${compile_files}下的Java文件"/>
+        <javac destdir="${classes}" debug="false" optimize="on" source="${source_jdk_version}"
+               target="${target_jdk_version}"
+               fork="true" memoryMaximumSize="512m" listfiles="false" srcdir="${basedir}"
+               executable="${compile_jdk_version}/bin/javac">
+            <src path="${basedir}/src/main/java"/>
+            <exclude name="**/.svn/**"/>
+            <compilerarg line="-encoding UTF8 "/>
+            <classpath refid="compile.classpath"/>
+        </javac>
+        <taskdef name="pretreatment" classname="com.fr.plugin.pack.PluginPretreatmentTask">
+            <classpath refid="compile.classpath"/>
+        </taskdef>
+        <pretreatment baseDir="${basedir}"/>
+    </target>
+
+    <target name="jar_classes">
+        <echo message="打Jar包:${jar_name}"/>
+        <delete file="${basedir}/${jar_name}"/>
+        <jar jarfile="${basedir}/${jar_name}">
+            <fileset dir="${classes}">
+            </fileset>
+        </jar>
+    </target>
+
+    <target name="super_jar" depends="prepare">
+        <antcall target="copy_resources">
+            <param name="resources_from" value="${basedir}"/>
+        </antcall>
+        <antcall target="compile_javas">
+            <param name="source_jdk_version" value="1.6"/>
+            <param name="target_jdk_version" value="1.6"/>
+            <param name="compile_jdk_version" value="${jdk.home}"/>
+            <param name="compile_files" value="${basedir}/src"/>
+        </antcall>
+        <echo message="compile plugin success!"/>
+
+        <antcall target="jar_classes">
+            <param name="jar_name" value="${plugin-jar}"/>
+        </antcall>
+        <delete dir="${classes}"/>
+
+    </target>
+
+    <target name="jar" depends="super_jar">
+        <antcall target="zip"/>
+    </target>
+
+    <target name="zip">
+        <property name="plugin-folder" value="fr-plugin-${plugin-name}-${plugin-version}"/>
+        <echo message="----------zip files----------"/>
+        <mkdir dir="${plugin-folder}"/>
+        <copy todir="${plugin-folder}">
+            <fileset dir=".">
+                <include name="${plugin-jar}"/>
+                <include name="plugin.xml"/>
+            </fileset>
+            <fileset dir="${libs}">
+                <include name="*.jar"/>
+                <include name="*.dll"/>
+            </fileset>
+        </copy>
+        <zip destfile="${basedir}/${plugin-folder}.zip" basedir=".">
+            <include name="${plugin-folder}/*.jar"/>
+            <include name="${plugin-folder}/*.dll"/>
+            <include name="${plugin-folder}/plugin.xml"/>
+        </zip>
+        <move file="${plugin-folder}.zip" todir="${destLoc}/install"/>
+    </target>
+</project>

plugin.xml

@@ -0,0 +1,22 @@
+<?xml version="1.0" encoding="UTF-8" standalone="no"?><plugin>
+    <id>com.fr.conf.db.demo</id>
+    <main-package>com.fr.conf.db.demo</main-package>
+    <name><![CDATA[插件使用数据库]]></name>
+    <active>yes</active>
+    <version>1.0</version>
+    <env-version>10.0~</env-version>
+    <jartime>2018-10-20</jartime>
+    <vendor>author</vendor>
+    <description><![CDATA[插件使用数据库，将必要的数据存入数据。]]></description>
+    <change-notes><![CDATA[
+        [2018-11-22]增加了插件功能说明。<br/>
+    ]]></change-notes>
+    <extra-core>
+        <DBAccessProvider class="com.fr.conf.db.demo.SystemConfigAccessBridge"/>
+    </extra-core>
+    <extra-decision>
+        <HttpHandlerProvider class="com.fr.conf.db.demo.InputHttpHandlerBridge"/>
+        <URLAliasProvider class="com.fr.conf.db.demo.InputUrlAliasBridge"/>
+    </extra-decision>
+    <function-recorder class="com.fr.conf.db.demo.SystemConfigAccessBridge"/>
+</plugin>

pom.xml

@@ -0,0 +1,18 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+
+    <parent>
+        <groupId>com.fr.plugin</groupId>
+        <artifactId>starter</artifactId>
+        <version>10.0</version>
+    </parent>
+    <packaging>jar</packaging>
+    <artifactId>demo-db-access</artifactId>
+    <build>
+        <!---如果要更改调试插件，改这里的配置就可以了-->
+        <outputDirectory>${project.basedir}/../webroot/WEB-INF/plugins/plugin-com.fr.conf.db.demo-1.0/classes</outputDirectory>
+    </build>
+</project>

readme.md

@@ -0,0 +1,11 @@
+# 插件读写数据库示例
+
+安装插件后，在浏览器中访问 [http://localhost:8075/webroot/decision/url/db/input](http://localhost:8075/webroot/decision/url/db/input)
+
+每次都会数据库写入一行数据，在这个页面会展示出来
+
+![1](screenshots/1.png)
+
+可以多刷新几次，再进入finedb数据中的fine_plugin_system_conf表查看
+
+![2](screenshots/2.png)

src/main/java/com/fr/conf/db/demo/InputHttpHandlerBridge.java

@@ -0,0 +1,14 @@
+package com.fr.conf.db.demo;
+
+import com.fr.conf.db.demo.fun.http.InputHttpHandler;
+import com.fr.decision.fun.HttpHandler;
+import com.fr.decision.fun.impl.AbstractHttpHandlerProvider;
+
+public class InputHttpHandlerBridge extends AbstractHttpHandlerProvider {
+    @Override
+    public HttpHandler[] registerHandlers() {
+        return new HttpHandler[]{
+                new InputHttpHandler()
+        };
+    }
+}

src/main/java/com/fr/conf/db/demo/InputUrlAliasBridge.java

@@ -0,0 +1,14 @@
+package com.fr.conf.db.demo;
+
+import com.fr.decision.fun.impl.AbstractURLAliasProvider;
+import com.fr.decision.webservice.url.alias.URLAlias;
+import com.fr.decision.webservice.url.alias.URLAliasFactory;
+
+public class InputUrlAliasBridge extends AbstractURLAliasProvider {
+    @Override
+    public URLAlias[] registerAlias() {
+        return new URLAlias[]{
+                URLAliasFactory.createPluginAlias("/db/input", "/db/input", false)
+        };
+    }
+}

src/main/java/com/fr/conf/db/demo/SystemConfigAccessBridge.java

@@ -0,0 +1,44 @@
+package com.fr.conf.db.demo;
+
+import com.fr.conf.db.demo.fun.SystemConfigDAO;
+import com.fr.conf.db.demo.fun.entity.SystemConfigEntity;
+import com.fr.db.fun.impl.AbstractDBAccessProvider;
+import com.fr.intelli.record.Focus;
+import com.fr.intelli.record.Original;
+import com.fr.record.analyzer.EnableMetrics;
+import com.fr.stable.db.accessor.DBAccessor;
+import com.fr.stable.db.dao.BaseDAO;
+import com.fr.stable.db.dao.DAOProvider;
+
+@EnableMetrics
+public class SystemConfigAccessBridge extends AbstractDBAccessProvider {
+
+    private static DBAccessor dbAccessor = null;
+
+    @Focus(id="com.fr.conf.db.demo", text = "", source = Original.PLUGIN)
+    public static DBAccessor getDbAccessor() {
+        return dbAccessor;
+    }
+
+    @Override
+    public DAOProvider[] registerDAO() {
+        return new DAOProvider[]{
+                new DAOProvider() {
+                    @Override
+                    public Class getEntityClass() {
+                        return SystemConfigEntity.class;
+                    }
+
+                    @Override
+                    public Class<? extends BaseDAO> getDAOClass() {
+                        return SystemConfigDAO.class;
+                    }
+                }
+        };
+    }
+
+    @Override
+    public void onDBAvailable(DBAccessor dbAccessor) {
+        SystemConfigAccessBridge.dbAccessor = dbAccessor;
+    }
+}

src/main/java/com/fr/conf/db/demo/fun/SystemConfigDao.java

@@ -0,0 +1,12 @@
+package com.fr.conf.db.demo.fun;
+
+import com.fr.conf.db.demo.fun.entity.SystemConfigEntity;
+import com.fr.stable.db.dao.BaseDAO;
+import com.fr.stable.db.session.DAOSession;
+
+public class SystemConfigDAO extends BaseDAO<SystemConfigEntity> {
+
+    public SystemConfigDAO(DAOSession daoSession) {
+        super(daoSession);
+    }
+}

src/main/java/com/fr/conf/db/demo/fun/entity/SystemConfigEntity.java

@@ -0,0 +1,56 @@
+package com.fr.conf.db.demo.fun.entity;
+
+import com.fr.stable.AssistUtils;
+import com.fr.stable.db.entity.BaseEntity;
+import com.fr.third.javax.persistence.Column;
+import com.fr.third.javax.persistence.Entity;
+import com.fr.third.javax.persistence.Table;
+
+import java.util.Date;
+
+@Entity
+@Table(name = "fine_plugin_system_conf")
+public class SystemConfigEntity extends BaseEntity {
+
+    @Column(name = "user")
+    private String user;
+
+    @Column(name = "salary")
+    private double salary;
+
+    @Column(name = "birth")
+    private Date birth;
+
+    public SystemConfigEntity() {
+
+    }
+
+    public String getUser() {
+        return user;
+    }
+
+    public void setUser(String user) {
+        this.user = user;
+    }
+
+    public double getSalary() {
+        return salary;
+    }
+
+    public void setSalary(double salary) {
+        this.salary = salary;
+    }
+
+    public Date getBirth() {
+        return birth;
+    }
+
+    public void setBirth(Date birth) {
+        this.birth = birth;
+    }
+
+    @Override
+    public String toString() {
+        return AssistUtils.toString(this);
+    }
+}

src/main/java/com/fr/conf/db/demo/fun/http/InputHttpHandler.java

@@ -0,0 +1,57 @@
+package com.fr.conf.db.demo.fun.http;
+
+import com.fr.conf.db.demo.SystemConfigAccessBridge;
+import com.fr.conf.db.demo.fun.SystemConfigDAO;
+import com.fr.conf.db.demo.fun.entity.SystemConfigEntity;
+import com.fr.data.NetworkHelper;
+import com.fr.decision.fun.impl.BaseHttpHandler;
+import com.fr.stable.db.action.DBAction;
+import com.fr.stable.db.dao.DAOContext;
+import com.fr.third.org.apache.commons.lang3.RandomUtils;
+import com.fr.third.springframework.web.bind.annotation.RequestMethod;
+import com.fr.third.org.apache.commons.lang3.RandomStringUtils;
+
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import java.io.PrintWriter;
+import java.util.Date;
+import java.util.UUID;
+
+public class InputHttpHandler extends BaseHttpHandler {
+    @Override
+    public RequestMethod getMethod() {
+        return RequestMethod.GET;
+    }
+
+    @Override
+    public String getPath() {
+        return "/db/input";
+    }
+
+    @Override
+    public boolean isPublic() {
+        return false;
+    }
+
+    @Override
+    public void handle(HttpServletRequest req, HttpServletResponse res) throws Exception {
+
+        SystemConfigEntity result = SystemConfigAccessBridge.getDbAccessor().runDMLAction(new DBAction<SystemConfigEntity>() {
+
+            @Override
+            public SystemConfigEntity run(DAOContext daoContext) throws Exception {
+                SystemConfigEntity entity = new SystemConfigEntity();
+                entity.setId(UUID.randomUUID().toString());
+                entity.setUser(RandomStringUtils.randomAlphabetic(5));
+                entity.setBirth(new Date());
+                entity.setSalary(RandomUtils.nextDouble(10000, 50000));
+                daoContext.getDAO(SystemConfigDAO.class).add(entity);
+                return entity;
+            }
+        });
+        PrintWriter writer = NetworkHelper.createPrintWriter(res);
+        writer.println("success insert data:" + result.toString() + " to database table:fine_plugin_system_conf");
+        writer.flush();
+        writer.close();
+    }
+}