mysql远程插入数据

### MySQL远程插入数据的方法 #### 使用FEDERATED存储引擎实现远程数据同步 可以通过创建一个基于`FEDERATED`存储引擎的表来访问远程MySQL服务器上的数据。这种方式允许本地数据库像操作本地表一样操作远程表中的数据[^1]。 ```sql CREATE TABLE federated_table ( id INT NOT NULL AUTO_INCREMENT, name VARCHAR(50), PRIMARY KEY (id) ) ENGINE=FEDERATED CONNECTION='mysql://user:password@remote_ip:port/database_name/remote_table'; ``` 上述SQL语句定义了一个名为`federated_table`的表，该表实际上是远程服务器上指定表的一个映射。任何针对此表的操作都会被转发至远程服务器执行。 --- #### 利用JDBC批量插入优化性能 如果需要通过程序接口（如Java JDBC）向远程MySQL数据库高效插入大量数据，则可以启用`rewriteBatchedStatements=true`参数以提升性能[^2]。以下是具体示例： ```java import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; public class MysqlBulkInsert { public static void main(String[] args) throws Exception { String jdbcUrl = "jdbc:mysql://remote_host:3306/test_db?useSSL=false&rewriteBatchedStatements=true"; String username = "your_username"; String password = "your_password"; try (Connection conn = DriverManager.getConnection(jdbcUrl, username, password)) { String sql = "INSERT INTO test_table (name) VALUES (?)"; try (PreparedStatement pstmt = conn.prepareStatement(sql)) { for (int i = 0; i < 1000; i++) { pstmt.setString(1, "Name_" + i); pstmt.addBatch(); if (i % 100 == 0) { // 每100条提交一次批处理 pstmt.executeBatch(); } } pstmt.executeBatch(); // 提交剩余的数据 } } catch (Exception e) { throw new RuntimeException(e); } } } ``` 在此代码片段中，启用了`rewriteBatchedStatements=true`选项后，JDBC驱动会将多条SQL语句组合成单个请求发送给MySQL服务端，从而减少网络开销并提高吞吐量。 --- #### LOAD DATA INFILE方法快速导入大批量数据 对于大规模数据集的传输需求，推荐使用`LOAD DATA INFILE`命令完成文件形式的大规模记录加载工作。下面是一个典型的应用场景说明： 假设有一份CSV格式的文件位于客户端机器上，并希望将其上传到远端数据库对应的表格里去。那么首先应当确认目标主机已开启安全设置支持外部源读取权限；其次编写如下指令即可达成目的: ```sql LOAD DATA LOCAL INFILE '/path/to/local_file.csv' INTO TABLE remote_table FIELDS TERMINATED BY ',' ENCLOSED BY '"' LINES TERMINATED BY '\n' IGNORE 1 ROWS; ``` 注意这里指定了路径为本地文件系统位置(`/path/to/local_file.csv`)以及字段分割符(`','`)等相关细节配置项。同时由于涉及隐私保护等因素考虑，默认情况下某些版本可能禁用了此项功能需手动调整my.cnf配置文档或者动态修改全局变量值才能生效。 ---