请帮我生成一段代码：在oracle数据库中，新建一张表traning.luo_test，使用生产者消费者模式、数据库连接池，读取文件aa.txt，将aa.txt文件中的数字写入新建表里面

首先，让我们分步骤来创建这个功能。我们将使用JDBC（Java Database Connectivity）来连接Oracle数据库，使用`java.sql.ConnectionPoolDataSource`来管理数据库连接池，然后使用`BufferedReader`从文件中读取数据，并将其插入到新表`luo_test`中。这里假设你已经设置了Oracle JDBC驱动（ojdbc jar），并配置了数据库连接信息。

以下是一个简单的示例代码：

import java.io.BufferedReader;
import java.io.FileReader;
import java.io.IOException;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;

import com.mchange.v2.c3p0.ComboPooledDataSource;

public class OracleProducerConsumer {
    private static final String DB_URL = "jdbc:oracle:thin:@//hostname:port/service_name";
    private static final String USER = "username";
    private static final String PASS = "password";

    // 创建C3P0数据库连接池
    private static ComboPooledDataSource cpds = new ComboPooledDataSource();
    static {
        cpds.setDriverClass("oracle.jdbc.driver.OracleDriver");
        cpds.setJdbcUrl(DB_URL);
        cpds.setUser(USER);
        cpds.setPassword(PASS);
        cpds.setMaxPoolSize(5); // 设置最大连接数
        cpds.setCheckoutTimeout(30000); // 设置超时时间
    }

    public static void main(String[] args) throws IOException, InterruptedException {
        // 消费者线程：读取文件并插入数据库
        new Thread(new Runnable() {
            @Override
            public void run() {
                try (BufferedReader reader = new BufferedReader(new FileReader("aa.txt"))) {
                    String line;
                    while ((line = reader.readLine()) != null) {
                        insertIntoTable(line);
                    }
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }, "File Reader").start();

        // 生产者线程：模拟数据库操作延迟
        new Thread(() -> {
            try {
                Thread.sleep(2000); // 延迟2秒以模拟数据库操作
                for (int i = 0; i < 10; i++) { // 插入10条数据
                    insertIntoTable(Integer.toString(i));
                    Thread.sleep(100); // 模拟每次插入后等待
                }
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }, "Database Insertor").start();
    }

    private static void insertIntoTable(String value) {
        Connection connection = null;
        PreparedStatement pstmt = null;
        try {
            connection = cpds.getConnection();
            String sql = "INSERT INTO luo_test(column_name) VALUES (?)";
            pstmt = connection.prepareStatement(sql);
            pstmt.setString(1, value);
            pstmt.executeUpdate();
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            if (pstmt != null) {
                pstmt.close();
            }
            if (connection != null && !connection.isClosed()) {
                connection.close();
            }
        }
    }
}

在这个例子中，我们使用了C3P0数据库连接池（c3p0.jar）来管理和复用数据库连接。生产者线程模拟数据库操作延迟，消费者线程负责读取文件并将数据插入到`luo_test`表中。

注意：这只是一个基本示例，实际应用中可能需要处理更多的异常情况，例如检查文件是否存在或表结构是否正确等。