Skip to content
Permalink

Comparing changes

This is a direct comparison between two commits made in this repository or its related repositories. View the default comparison for this range or learn more about diff comparisons.

Open a pull request

Create a new pull request by comparing changes across two branches. If you need to, you can also . Learn more about diff comparisons here.
base repository: alibaba/canal
Failed to load repositories. Confirm that selected base ref is valid, then try again.
Loading
base: be0a68a1b5aa9885c2b21ed9d6fca16eafcae075
Choose a base ref
..
head repository: alibaba/canal
Failed to load repositories. Confirm that selected head ref is valid, then try again.
Loading
compare: f24ab0a14d1dfef6481b291c53543d834ebcdebd
Choose a head ref
Showing with 2 additions and 4 deletions.
  1. +2 −4 ...t-adapter/rdb/src/main/java/com/alibaba/otter/canal/client/adapter/rdb/support/BatchExecutor.java
6 changes: 2 additions & 4 deletions ...r/rdb/src/main/java/com/alibaba/otter/canal/client/adapter/rdb/support/BatchExecutor.java
View file
Original file line number Diff line number Diff line change
@@ -14,8 +14,6 @@
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import com.alibaba.druid.pool.DruidDataSource;

/**
* sql批量执行器
*
@@ -26,11 +24,11 @@ public class BatchExecutor implements Closeable {

private static final Logger logger = LoggerFactory.getLogger(BatchExecutor.class);

private DruidDataSource dataSource;
private DataSource dataSource;
private Connection conn;
private AtomicInteger idx = new AtomicInteger(0);

public BatchExecutor(DruidDataSource dataSource){
public BatchExecutor(DataSource dataSource){
this.dataSource = dataSource;
}