Connection::createTable

public function createTable($tableName, $fields, $primary = array(), $autoincrement = array());

/**
 * Creates primary index on column(s)
 * @api
 *
 * @param string $tableName Name of the table.
 * @param string|string[] $columnNames Name of the column or array of column names to be included into the index.
 *
 * @return Result
 * @throws SqlQueryException
 */
public function createPrimaryIndex($tableName, $columnNames)
{
	if (!is_array($columnNames))
	{
		$columnNames = array($columnNames);
	}

	foreach ($columnNames as &$columnName)
	{
		$columnName = $this->getSqlHelper()->quote($columnName);
	}

	$sql = 'ALTER TABLE '.$this->getSqlHelper()->quote($tableName).' ADD PRIMARY KEY('.join(', ', $columnNames).')';

	return $this->query($sql);
}