extend/alipay/pay/lotusphp_runtime/DB/DbHandle.php

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

<?php
class LtDbHandle
{
	public $configHandle;
	public $group;
	public $node;
	public $role = "master";
	public $connectionAdapter;
	public $connectionResource;
	public $sqlAdapter;
	protected $connectionManager;
	private $servers;

	public function __construct()
	{
	}

	public function init()
	{
		if(empty($this->servers))
		{
			$this->servers = $this->configHandle->get("db.servers");
		}
		$this->connectionManager = new LtDbConnectionManager;
		$this->connectionManager->configHandle = $this->configHandle;
		$this->sqlAdapter = $this->getCurrentSqlAdapter();
		$connectionInfo = $this->connectionManager->getConnection($this->group, $this->node, $this->role);
		$this->connectionAdapter = $connectionInfo["connectionAdapter"];
		$this->connectionResource = $connectionInfo["connectionResource"];
	}

	/**
	 * Trancaction methods
	 */
	public function beginTransaction()
	{
		return $this->connectionAdapter->exec($this->sqlAdapter->beginTransaction(), $this->connectionResource);
	}

	public function commit()
	{
		return $this->connectionAdapter->exec($this->sqlAdapter->commit(), $this->connectionResource);
	}

	public function rollBack()
	{
		return $this->connectionAdapter->exec($this->sqlAdapter->rollBack(), $this->connectionResource);
	}

	/**
	 * Execute an sql query
	 * 
	 * @param  $sql 
	 * @param  $bind 
	 * @param  $forceUseMaster 
	 * @return false on query failed
	 *           --sql type--                         --return value--
	 *           SELECT, SHOW, DESECRIBE, EXPLAIN     rowset or NULL when no record found
	 *           INSERT                               the ID generated for an AUTO_INCREMENT column
	 *           UPDATE, DELETE, REPLACE              affected count