并发写入mysql数据库的例子

假设有一个多线程程序，每个线程都需要往MySQL数据库写入数据，以下是一个并发写入MySQL数据库的例子：

首先，需要在程序的初始化阶段创建MySQL数据库连接池，以便多个线程共享数据库连接，避免频繁创建和销毁连接的开销。
在每个线程中，获取一个数据库连接，然后执行SQL语句，将数据写入数据库。需要注意的是，不同的线程不能共享同一个数据库连接，否则会出现线程安全问题。
在写入数据的过程中，可以使用数据库事务来保证数据的一致性和完整性。事务可以将多个SQL操作封装在一起，在所有操作都成功完成后提交事务，如果其中任何一个操作失败，则回滚整个事务。

以下是一个简单的Java程序，演示了如何实现并发写入MySQL数据库：

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;

public class ConcurrentMySQLWriter {

    private static final String URL = "jdbc:mysql://localhost:3306/mydb";
    private static final String USER = "root";
    private static final String PASSWORD = "password";

    public static void main(String[] args) throws Exception {
        int numThreads = 10;
        int numWritesPerThread = 1000;
        Thread[] threads = new Thread[numThreads];
        for (int i = 0; i < numThreads; i++) {
            threads[i] = new Thread(new Writer(numWritesPerThread));
            threads[i].start();
        }
        for (int i = 0; i < numThreads; i++) {
            threads[i].join();
        }
    }

    static class Writer implements Runnable {

        private int numWrites;

        public Writer(int numWrites) {
            this.numWrites = numWrites;
        }

        @Override
        public void run() {
            try {
                Connection conn = DriverManager.getConnection(URL, USER, PASSWORD);
                conn.setAutoCommit(false);
                PreparedStatement stmt = conn.prepareStatement("INSERT INTO mytable (col1, col2) VALUES (?, ?)");
                for (int i = 0; i < numWrites; i++) {
                    stmt.setInt(1, i);
                    stmt.setString(2, "value" + i);
                    stmt.executeUpdate();
                }
                conn.commit();
                conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}

这个程序创建了10个线程，每个线程往MySQL数据库写入1000条数据。在每个线程中，先获取一个数据库连接，然后循环执行1000次插入操作，最后提交事务并关闭连接。

需要注意的是，这个程序中没有使用连接池，每个线程都会创建自己的数据库连接，这会导致大量的数据库连接创建和销毁开销，不适合高并发场景。在实际应用中，需要使用连接池来优化性能