Используя подключение к базе данных ODBC, получите доступ к базе данных с помощью параллельного пула (требуется Toolbox™ параллельных вычислений). Параллельный импорт данных из нескольких запросов SQL.

Для каждого работника пула установлен драйвер ODBC. Кроме того, каждый работник имеет настроенный источник данных ODBC. Дополнительные сведения см. в разделе configureODBCDataSource функция.

Запустите параллельный пул.

pool = gcp;

Starting parallel pool (parpool) using the 'local' profile ...
Connected to the parallel pool (number of workers: 6).

Инициализируйте параллельный пул с помощью источника данных ODBC. Этот источник данных настраивает драйвер ODBC для базы данных Microsoft ® SQL Server ® с проверкой подлинности Windows ®. Укажите пустое имя пользователя и пароль.

datasource = "MS SQL Server Auth";
username = "";
password = "";
c = createConnectionForPool(pool,datasource,username,password);

Определите запросы SQL.

sqlqueries = ["SELECT * FROM invoice" ...
    "SELECT * FROM inventorytable" ...
    "SELECT * FROM producttable"];

Параллелизируйте доступ к данным с помощью корзины запросов путем вызова parfor функция.

Для каждого работника извлеките объект подключения к базе данных, выполните SQL-запросы и импортируйте данные локально.

parfor i = 1:length(sqlqueries)

    conn = c.Value;

    results = fetch(conn,sqlqueries(i));

    allresults{i} = results;

end

Просмотрите результаты для всех запросов. Массив ячеек содержит три таблицы, по одной для каждого набора результатов запроса.

allresults

allresults = 1×3 cell array
    {10×5 table}    {13×4 table}    {15×5 table}

Закройте параллельный пул.

delete(pool);

Используя подключение к базе данных JDBC, получите доступ к базе данных с помощью параллельного пула (требуется Toolbox™ параллельных вычислений). Параллельный импорт данных из нескольких запросов SQL.

Чтобы инициализировать параллельный пул с подключением к базе данных JDBC, необходимо настроить источник данных JDBC. Дополнительные сведения см. в разделе databaseConnectionOptions функция.

Запустите параллельный пул.

pool = gcp;

Starting parallel pool (parpool) using the 'local' profile ...
Connected to the parallel pool (number of workers: 6).

Инициализация параллельного пула с использованием источника данных JDBC MSSQLServerJDBCAuth. Этот источник данных настраивает драйвер JDBC для базы данных Microsoft ® SQL Server ® с проверкой подлинности Windows ®. Укажите пустое имя пользователя и пароль.

datasource = "MSSQLServerJDBCAuth";
username = "";
password = "";
c = createConnectionForPool(pool,datasource,username,password);

Определите запросы SQL.

sqlqueries = ["SELECT * FROM invoice" ...
    "SELECT * FROM inventorytable" ...
    "SELECT * FROM producttable"];

Параллелизируйте доступ к данным с помощью корзины запросов путем вызова parfor функция.

Для каждого работника извлеките объект подключения к базе данных, выполните SQL-запросы и импортируйте данные локально.

parfor i = 1:length(sqlqueries)

    conn = c.Value;

    results = fetch(conn,sqlqueries(i));

    allresults{i} = results;

end

Просмотрите результаты для всех запросов. Массив ячеек содержит три таблицы, по одной для каждого набора результатов запроса.

allresults

allresults = 1×3 cell array
    {10×5 table}    {13×4 table}    {15×5 table}

Закройте параллельный пул.

delete(pool);