在项目中,经常有批量提交数据,因为数据的产生比较快,每秒大概有2500条记录,外网数据库用了阿里云的DRDS(MySQL),内网数据库是Oracle 11g,后台开发用Go,因为业务模型的需要,需要把这些数据在插入到表A的同时,还需要合并到表B,现在用批量事务处理,每3000条做一次提交,发现很快就把数据库连接用完,不管是Oracle也好、DRDS(MySQL)也好,很快就把连接数用完了,后来发现是插入和合并效率比较慢,3000条数据的提交要30多秒,然后看了golang的oci8驱动库,发现他并没有实现loader stream的功能,mysql以前也不是特别熟悉,也不清楚有什么语句是可以直接用类似Oracle装载方式进行大批量数据导入的。
希望能给一个比较好的解决方案。
oracle的loader stream方式说明在这里,这个是Oracle的SQL Loader的官方SDK版本说明,SQL Loader是对这个接口的实现。