nifi-mybatis是一个轻量级的数据库访问工具，帮助开发人员在NiFi框架下通过MyBatis访问数据库，并以Controller Service的形式暴露给Processor。
- 通过继承的方式实现数据库访问Controller Service;
- 支持类Spring的依赖注入;
- 支持NiFi内置的DBCPService/DBCPConnectionPool;
- 提供线程安全的数据库访问对象；
- 事务管理；
<dependency>
<groupId>org.indunet</groupId>
<artifactId>nifi-mybatis</artifactId>
<version>1.0.7</version>
</dependency>public interface VehicleService extends ControllerService {
List<VehicleModelDO> listVehicleModel();
List<VehicleDO> listVehicle();
}Step 2. 集成AbstractNiBatisService类并实现上述接口，重写initialize方法，指定MyBatis Mapper的路径，建议MyBatis接口类和XML采用相同命名，并放置在相同目录下。最后调用this.autowire(this)实现依赖注入；
public class VehicleControllerService extends AbstractNiBatisService implements VehicleService {
@Autowired
VehicleMapper vehicleMapper;
@Autowired
VehicleModelMapper vehicleModelMapper;
@Override
protected void initialize(Configuration conf) {
conf.addMappers("org.indunet.nifi.mapper");
this.autowire(this);
}
@Override
public List<VehicleDO> listVehicle() {
return this.vehicleMapper.listVehicle();
}
@Override
public List<VehicleModelDO> listVehicleModel() {
return this.vehicleModelMapper.listVehicleModel();
}
}service nifi restart
- Java 1.8+
- Maven 3.5+
nifi-mybatis is released under the Apache 2.0 license.
Copyright 1999-2020 indunet.org group Holding Ltd.
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 the following link.
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.
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent