ConnectionTest.php 4.67 KB
Newer Older
w  
Qiang Xue committed
1 2
<?php

Qiang Xue committed
3
namespace yiiunit\framework\db;
Qiang Xue committed
4

Qiang Xue committed
5
use yii\db\Connection;
6
use yii\db\Transaction;
w  
Qiang Xue committed
7

8 9 10 11
/**
 * @group db
 * @group mysql
 */
Alexander Makarov committed
12
class ConnectionTest extends DatabaseTestCase
w  
Qiang Xue committed
13
{
14 15 16 17
    public function testConstruct()
    {
        $connection = $this->getConnection(false);
        $params = $this->database;
Qiang Xue committed
18

19 20 21 22
        $this->assertEquals($params['dsn'], $connection->dsn);
        $this->assertEquals($params['username'], $connection->username);
        $this->assertEquals($params['password'], $connection->password);
    }
w  
Qiang Xue committed
23

24 25 26
    public function testOpenClose()
    {
        $connection = $this->getConnection(false, false);
Qiang Xue committed
27

28 29
        $this->assertFalse($connection->isActive);
        $this->assertEquals(null, $connection->pdo);
w  
Qiang Xue committed
30

31 32 33
        $connection->open();
        $this->assertTrue($connection->isActive);
        $this->assertTrue($connection->pdo instanceof \PDO);
w  
Qiang Xue committed
34

35 36 37
        $connection->close();
        $this->assertFalse($connection->isActive);
        $this->assertEquals(null, $connection->pdo);
w  
Qiang Xue committed
38

39 40 41 42 43
        $connection = new Connection;
        $connection->dsn = 'unknown::memory:';
        $this->setExpectedException('yii\db\Exception');
        $connection->open();
    }
w  
Qiang Xue committed
44

45 46 47 48 49
    public function testGetDriverName()
    {
        $connection = $this->getConnection(false, false);
        $this->assertEquals($this->driverName, $connection->driverName);
    }
Qiang Xue committed
50

51 52 53 54 55 56 57
    public function testQuoteValue()
    {
        $connection = $this->getConnection(false);
        $this->assertEquals(123, $connection->quoteValue(123));
        $this->assertEquals("'string'", $connection->quoteValue('string'));
        $this->assertEquals("'It\\'s interesting'", $connection->quoteValue("It's interesting"));
    }
Qiang Xue committed
58

59 60 61 62 63 64 65 66 67 68
    public function testQuoteTableName()
    {
        $connection = $this->getConnection(false);
        $this->assertEquals('`table`', $connection->quoteTableName('table'));
        $this->assertEquals('`table`', $connection->quoteTableName('`table`'));
        $this->assertEquals('`schema`.`table`', $connection->quoteTableName('schema.table'));
        $this->assertEquals('`schema`.`table`', $connection->quoteTableName('schema.`table`'));
        $this->assertEquals('{{table}}', $connection->quoteTableName('{{table}}'));
        $this->assertEquals('(table)', $connection->quoteTableName('(table)'));
    }
Qiang Xue committed
69

70 71 72 73 74 75 76 77 78 79 80
    public function testQuoteColumnName()
    {
        $connection = $this->getConnection(false);
        $this->assertEquals('`column`', $connection->quoteColumnName('column'));
        $this->assertEquals('`column`', $connection->quoteColumnName('`column`'));
        $this->assertEquals('`table`.`column`', $connection->quoteColumnName('table.column'));
        $this->assertEquals('`table`.`column`', $connection->quoteColumnName('table.`column`'));
        $this->assertEquals('[[column]]', $connection->quoteColumnName('[[column]]'));
        $this->assertEquals('{{column}}', $connection->quoteColumnName('{{column}}'));
        $this->assertEquals('(column)', $connection->quoteColumnName('(column)'));
    }
81

82 83 84 85 86 87 88
    public function testTransaction()
    {
        $connection = $this->getConnection(false);
        $this->assertNull($connection->transaction);
        $transaction = $connection->beginTransaction();
        $this->assertNotNull($connection->transaction);
        $this->assertTrue($transaction->isActive);
89

90
        $connection->createCommand()->insert('profile', ['description' => 'test transaction'])->execute();
91

92 93 94
        $transaction->rollBack();
        $this->assertFalse($transaction->isActive);
        $this->assertNull($connection->transaction);
95

96
        $this->assertEquals(0, $connection->createCommand("SELECT COUNT(*) FROM profile WHERE description = 'test transaction';")->queryScalar());
97

98 99 100 101 102
        $transaction = $connection->beginTransaction();
        $connection->createCommand()->insert('profile', ['description' => 'test transaction'])->execute();
        $transaction->commit();
        $this->assertFalse($transaction->isActive);
        $this->assertNull($connection->transaction);
103

104 105
        $this->assertEquals(1, $connection->createCommand("SELECT COUNT(*) FROM profile WHERE description = 'test transaction';")->queryScalar());
    }
106

107 108 109
    public function testTransactionIsolation()
    {
        $connection = $this->getConnection(true);
110

111 112
        $transaction = $connection->beginTransaction(Transaction::READ_UNCOMMITTED);
        $transaction->commit();
113

114 115
        $transaction = $connection->beginTransaction(Transaction::READ_COMMITTED);
        $transaction->commit();
116

117 118
        $transaction = $connection->beginTransaction(Transaction::REPEATABLE_READ);
        $transaction->commit();
119

120 121 122
        $transaction = $connection->beginTransaction(Transaction::SERIALIZABLE);
        $transaction->commit();
    }
123

w  
Qiang Xue committed
124
}