adt/bulk-fetcher

维护者

详细信息

github.com/AppsDevTeam/BulkFetcher

源代码

问题

安装次数: 25,514

依赖: 0

建议者: 0

安全: 0

星标: 0

关注者: 15

分支: 0

公开问题: 0

v5.0 2024-06-19 08:56 UTC

Requires (Dev)

MIT, BSD-3-Clause, GPL-2.0, GPL-3.0 20b56017c27e3ada3533e04e513e0c8b67bafe4c

This package is auto-updated.

Last update: 2024-09-19 09:39:07 UTC

README

\ADT\BulkFetcher\Factory 可以与以下一起使用

  • \Kdyby\Doctrine\ResultSet
  • \Doctrine\ORM\QueryBuilder
  • \Kdyby\Doctrine\NativeQueryBuilder

安装

通过 composer

composer require adt/bulk-fetcher

完整示例

整个批量都在事务中。

$qb = $entityManager->createQueryBuilder('user');

try {
	$entityManager->beginTransaction();	
	
	$data = \ADT\BulkFetcher\Factory::create($qb, 100);
	$data->onBeforeFetch[] = function() use ($entityManager) {
		$entityManager->commit();
		$entityManager->clear();
		$entityManager->beginTransaction();
	};
	
	foreach ($data as $key => $row) {
		// code
	}
	
	$entityManager->commit();

} catch (\Exception $e) {
	$entityManager->rollback();
	throw $e;
}