任务执行环境
配置信息类com.runqianapp.schedule.utils.ScheduleConfig
用户编写自定义任务时,通过配置信息类获取/设置配置信息,获取/设置数据库访问接口类。
有以下可供调用的方法:
方法:public static void setRunDBA(IDBAccess runDBA)
参数说明:IDBAccess接口的实现类名称。IDBAccess接口说明见下文。
功能说明:设置数据库访问类。如果未使用该方法设置数据库连接,那么,调度引擎将引用默认连接;如果使用该方法设置了数据库连接,那么引擎将使用该连接。
方法:public static IDBAccess getRunDBA()
功能说明:得到DBA。
返回值:IDBAccess对象。
方法:public boolean setConfig(String configName, String configValue)
参数说明:configName配置名称,configValue配置值。
功能说明:设置配置信息。调度引擎提供了一个配置信息,可以通过这个方法改变。如:发送邮件的用户名。
返回值:布尔型,true为成功,false为失败。
方法:public String getConfig(String configName)
参数说明: 配置名称。
功能说明:获取调度引擎的配置信息。
接口类:com.runqianapp.schedule.interfaces.IDBAccess
本接口允许用户自定义数据操作类,用于执行数据库操作。
接口说明:
用于处理调度引擎中对数据库数据的查询、更新等数据库操作
可用方法:
方法:boolean open()
功能说明:打开数据库连接
返回值: 是否成功打开连接
方法:boolean close()
功能说明:关闭数据库连接
返回值: 是否成功关闭连接
方法:ResultSet executeQuery(String sql, Object[] params)
功能说明:执行查询语句。这里使用PreparedStatemet执行查询,防止SQL注入
返回值: 查询结果
方法:int executeUpdate(String sql, Object[] params)
功能说明:执行更新语句。这里使用PreparedStatemet执行更新,防止SQL注入
返回值: 更新的数据行数
示例:在自定义任务中使用数据库