Class DataloadMapper

lib/Db/DataloadMapper.php:15–243

use Psr\Log\LoggerInterface;

class DataloadMapper {
	private $userId;
	private $db;
	private $logger;
	const TABLE_NAME = 'analytics_dataload';

	public function __construct(
		$userId,
		IDBConnection $db,
		LoggerInterface $logger
	) {
		$this->userId = $userId;
		$this->db = $db;
		$this->logger = $logger;
		self::TABLE_NAME;
	}

	public function beginTransaction() {
		$this->db->beginTransaction();
	}

	public function commit() {
		$this->db->commit();
	}

	public function rollBack() {
		$this->db->rollBack();
	}

	/**
	 * create a new dataload
	 *
	 * @NoAdminRequired
	 * @param int $datasetId
	 * @param int $datasourceId
	 * @return integer
	 * @throws \OCP\DB\Exception
	 */
	public function create(int $datasetId, int $datasourceId) {
		$sql = $this->db->getQueryBuilder();
		$sql->insert(self::TABLE_NAME)->values([
				'user_id' => $sql->createNamedParameter($this->userId),
				'name' => $sql->createNamedParameter('New'),
				'dataset' => $sql->createNamedParameter($datasetId),
				'datasource' => $sql->createNamedParameter($datasourceId),
				'option' => $sql->createNamedParameter('{}'),
			]);
		$sql->executeStatement();
		return (int)$sql->getLastInsertId();
	}

	/**
	 * get all data loads for a dataset
	 *
	 * @NoAdminRequired
	 * @param int $datasetId
	 * @return array
	 */