You need to enable JavaScript to run this app.
最新活动
产品
解决方案
定价
生态与合作
支持与服务
开发者
了解我们

JdbcTemplate没有自动注入(&quartz)

在配置文件中手动将JdbcTemplate注入到quartz中。示例代码如下:

@Configuration public class QuartzConfig {

@Autowired
private DataSource dataSource;

@Autowired
private JdbcTemplate jdbcTemplate;

@Bean
public SchedulerFactoryBean schedulerFactory() {
    SchedulerFactoryBean factory = new SchedulerFactoryBean();

    //将JdbcTemplate注入到JobDetailFactoryBean中
    JobDetailFactoryBean jobDetailFactoryBean = new JobDetailFactoryBean();
    jobDetailFactoryBean.setJobClass(MyJob.class);
    jobDetailFactoryBean.setDurability(true);
    jobDetailFactoryBean.setApplicationContextSchedulerContextKey("applicationContextKey");
    jobDetailFactoryBean.afterPropertiesSet();

    JobDetail jobDetail = jobDetailFactoryBean.getObject();
    JobDataMap jobDataMap = jobDetail.getJobDataMap();
    jobDataMap.put("jdbcTemplate", jdbcTemplate);

    //将JdbcTemplate注入到JobFactory中
    JobFactory jobFactory = new MyJobFactory();
    ((MyJobFactory) jobFactory).setJdbcTemplate(jdbcTemplate);

    factory.setJobFactory(jobFactory);
    factory.setDataSource(dataSource);
    factory.setJobDetails(jobDetail);
    factory.setAutoStartup(true);

    return factory;
}

}

public class MyJob implements Job {

@Override
public void execute(JobExecutionContext context) throws JobExecutionException {
    //获取JdbcTemplate对象并进行操作
    JdbcTemplate jdbcTemplate = (JdbcTemplate) context.getMergedJobDataMap().get("jdbcTemplate");
    jdbcTemplate.update("INSERT INTO user(name, age) VALUES ('张三', 25)");
}

}

public class MyJobFactory extends SpringBeanJobFactory {

private JdbcTemplate jdbcTemplate;

@Override
protected Object createJobInstance(TriggerFiredBundle bundle) throws Exception {
    Object jobInstance = super.createJobInstance(bundle);
    BeanWrapper beanWrapper = new BeanWrapperImpl(jobInstance);
    beanWrapper.setAutoGrowNestedPaths(true);
    beanWrapper.setPropertyValue("jdbcTemplate", jdbcTemplate);
    return jobInstance;
}

public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {
    this.jdbcTemplate = jdbcTemplate;
}

}

在上述配置中,我们手动将JdbcTemplate注入到JobDetailFactoryBean和JobFactory中,最终在Job类中

本文内容通过AI工具匹配关键字智能整合而成,仅供参考,火山引擎不对内容的真实、准确或完整作任何形式的承诺。如有任何问题或意见,您可以通过联系service@volcengine.com进行反馈,火山引擎收到您的反馈后将及时答复和处理。
展开更多
面向开发者的云福利中心,ECS 60元/年,域名1元起,助力开发者快速在云上构建可靠应用

社区干货

达梦@记一次国产数据库适配思考过程|社区征文

没有get到对达梦数据库做集成,小编这里采用的jdk1.8,安装的达梦数据库也是DM8,所以这里引入:DmJdbcDriver18,其相对于DmJdbcDriver17作出了很大的改进。i、本地引入的方式在pom.xml文件中,引入依赖jar``` com.... Template,以及为每个@Mapper注册了一个Mapper实现类-MyBatis->@Autowired注入一个Mapper。当我们自己为容器中注入SqlSessionFactory对象,从容器中取dataSource(当引入spring-boot-starter-jdbc时会自动配置)作为...

计算引擎在K8S上的实践|社区征文

如果没有则需要自己去构建一个。因为我们使用了hive的元数据信息,所有镜像中打入了mysql的jar包。```yamlapiVersion: apps/v1kind: Deploymentmetadata: name: spark-thrift-server-test namespace: defau... template: metadata: labels: app.kubernetes.io/name: spark-thrift-server-test app.kubernetes.io/version: v3.1.1 spec: serviceAccountName: thrift-server hos...

干货 | BitSail Connector 开发详解系列一:Source

"jdbc_url": "jdbc:clickhouse://localhost:8123", "db_name": "default", "table_name": "test_ch_table", "split_field": "id", "split_config": "{"name": "id", "lower_bound": 0, "upper_bound": "... String.format(SOURCE_INSTANCE_NAME_TEMPLATE, cluster, topic, consumerGroup, UUID.randomUUID() )); try { consumer.start(); Collection messageQueue...

[BitSail] Connector开发详解系列三:SourceReader

只要我们保证SourceSplitCoordinator分配给不同SourceReader的切片没有交集,在SourceReader的执行周期中,我们就可以不考虑任何有关并发的细节。![picture.image](https://p6-volc-community-sign.byteimg.com/t... consumer.setInstanceName(String.format(SOURCE_READER_INSTANCE_NAME_TEMPLATE, cluster, topic, consumerGroup, UUID.randomUUID())); consumer.setConsumerPullTimeoutMillis(pollTimeout); ...

特惠活动

热门爆款云服务器

100%性能独享,更高内存性能更佳,学习测试、web前端、企业应用首选,每日花费低至0.55元
60.00/1212.00/年
立即购买

域名注册服务

cn/top/com等热门域名,首年低至1元,邮箱建站必选
1.00/首年起32.00/首年起
立即购买

DCDN国内流量包100G

同时抵扣CDN与DCDN两种流量消耗,加速分发更实惠
2.00/20.00/年
立即购买

JdbcTemplate没有自动注入(&quartz) -优选内容

达梦@记一次国产数据库适配思考过程|社区征文
没有get到对达梦数据库做集成,小编这里采用的jdk1.8,安装的达梦数据库也是DM8,所以这里引入:DmJdbcDriver18,其相对于DmJdbcDriver17作出了很大的改进。i、本地引入的方式在pom.xml文件中,引入依赖jar``` com.... Template,以及为每个@Mapper注册了一个Mapper实现类-MyBatis->@Autowired注入一个Mapper。当我们自己为容器中注入SqlSessionFactory对象,从容器中取dataSource(当引入spring-boot-starter-jdbc时会自动配置)作为...
Java应用接入
放置支持的插件的jar包 -- apm-feign-default-http-9.x-plugin-1.0.0-stable.jar -- apm-httpClient-4.x-plugin-1.0.0-stable.jar -- apm-jdbc-commons-1.0.0-stable.jar `-- ...jar 执行以下命令,集成... 开启JavaAgent自动注入。 PowerShell apmplus.volcengine.com/java-agent.version: 'latest'添加完成后,yaml配置如下所示: YAML ---apiVersion: apps/v1kind: Deploymentmetadata: ...spec: template: metada...
计算引擎在K8S上的实践|社区征文
如果没有则需要自己去构建一个。因为我们使用了hive的元数据信息,所有镜像中打入了mysql的jar包。```yamlapiVersion: apps/v1kind: Deploymentmetadata: name: spark-thrift-server-test namespace: defau... template: metadata: labels: app.kubernetes.io/name: spark-thrift-server-test app.kubernetes.io/version: v3.1.1 spec: serviceAccountName: thrift-server hos...
配置指引
如果系统没有该用户,则在该参数设置为 true 时自动创建 worker_max_cpu_load_avg -1 worker 最大 cpuload 均值,只有高于系统 cpuload 均值时,worker 服务才能被派发任务。默认值为 -1,会在运行时设置为当前机器 CP... 集群化的 Quartz 可以通过负载均衡提高性能,并且有更好的容错性,如果应用在集群中设置为 false 会出错 spring_quartz_properties_org_quartz_jobStore_class org.quartz.impl.jdbcjobstore.JobStoreTX 所有的 quar...

JdbcTemplate没有自动注入(&quartz) -相关内容

[BitSail] Connector开发详解系列三:SourceReader

只要我们保证SourceSplitCoordinator分配给不同SourceReader的切片没有交集,在SourceReader的执行周期中,我们就可以不考虑任何有关并发的细节。![picture.image](https://p6-volc-community-sign.byteimg.com/t... consumer.setInstanceName(String.format(SOURCE_READER_INSTANCE_NAME_TEMPLATE, cluster, topic, consumerGroup, UUID.randomUUID())); consumer.setConsumerPullTimeoutMillis(pollTimeout); ...

干货 | BitSail Connector开发详解系列一:Source

通过JDBC方式连接的数据库,包括MySql、Oracle、SqlServer、Kudu、ClickHouse等。 这里数据源的特点是以java.sql.ResultSet的接口形式返回获取的数据,对于这类数据库,我们往往将TypeInfoConverter对... String.format(SOURCE_INSTANCE_NAME_TEMPLATE, cluster, topic, consumerGroup, UUID.randomUUID() )); ...

任务接口

1自动调度(dorado调度) "scheduleTimeType": 0, // 运行频率 0: 精确时间; 1: 间隔时间 // 以scheduleTimeSettings= ["13,15,20", "6"]为例 // hourly:13:06、15:06、20:06这三个点进行调度 // daily:... "jdbcConnectionString": null, "shardNum": 0, "chPartitionType": null, "clusterName": "cn", "shardColumn": null, "bootstrapServers":...

热门爆款云服务器

100%性能独享,更高内存性能更佳,学习测试、web前端、企业应用首选,每日花费低至0.55元
60.00/1212.00/年
立即购买

域名注册服务

cn/top/com等热门域名,首年低至1元,邮箱建站必选
1.00/首年起32.00/首年起
立即购买

DCDN国内流量包100G

同时抵扣CDN与DCDN两种流量消耗,加速分发更实惠
2.00/20.00/年
立即购买

可视化建模 Open API

1自动调度(dorado调度) "scheduleTimeType": 0, // 运行频率 0: 精确时间; 1: 间隔时间 // 以scheduleTimeSettings= ["13,15,20", "6"]为例 // hourly:13:06、15:06、20:06这三个点进行调度 // daily:... "jdbcConnectionString": null, "shardNum": 0, "chPartitionType": null, "clusterName": "cn", "shardColumn": null, "bootstrapServers":...

UDF

需要注意两点: 当您首次创建函数时(执行 Create Function SQL)会触发 FaaS 的初始化,这个过程一般会耗时 1 min 左右,也会随着 UDF Jar 包增大而耗时增加。 基于 FaaS 自动扩缩容的能力,当您一段时间没有执行 UDF ... jdbc-1.2.2-bd97.jarhive-metastore-1.2.2-bd97.jarhk2-api-2.6.1.jarhk2-locator-2.6.1.jarhk2-utils-2.6.1.jarhtrace-core-3.0.4.jarhttpclient-4.5.6.jarhttpcore-4.4.12.jarhudi-bytelake-bundle_2.12-0.7.0-b...

特惠活动

热门爆款云服务器

100%性能独享,更高内存性能更佳,学习测试、web前端、企业应用首选,每日花费低至0.55元
60.00/1212.00/年
立即购买

域名注册服务

cn/top/com等热门域名,首年低至1元,邮箱建站必选
1.00/首年起32.00/首年起
立即购买

DCDN国内流量包100G

同时抵扣CDN与DCDN两种流量消耗,加速分发更实惠
2.00/20.00/年
立即购买

产品体验

体验中心

云服务器特惠

云服务器
云服务器ECS新人特惠
立即抢购

白皮书

一图详解大模型
浓缩大模型架构,厘清生产和应用链路关系
立即获取

最新活动

爆款1核2G共享型服务器

首年60元,每月仅需5元,限量秒杀
立即抢购

火山引擎增长体验专区

丰富能力激励企业快速增长
查看详情

数据智能VeDI

易用的高性能大数据产品家族
了解详情

一键开启云上增长新空间

立即咨询