DatabaseMigratorIntegrationTest.php 12 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280
  1. <?php
  2. namespace Illuminate\Tests\Database;
  3. use Illuminate\Console\OutputStyle;
  4. use Illuminate\Container\Container;
  5. use Illuminate\Database\Capsule\Manager as DB;
  6. use Illuminate\Database\Migrations\DatabaseMigrationRepository;
  7. use Illuminate\Database\Migrations\Migrator;
  8. use Illuminate\Filesystem\Filesystem;
  9. use Illuminate\Support\Facades\Facade;
  10. use Illuminate\Support\Str;
  11. use Mockery as m;
  12. use PHPUnit\Framework\TestCase;
  13. class DatabaseMigratorIntegrationTest extends TestCase
  14. {
  15. protected $db;
  16. protected $migrator;
  17. /**
  18. * Bootstrap Eloquent.
  19. *
  20. * @return void
  21. */
  22. protected function setUp(): void
  23. {
  24. $this->db = $db = new DB;
  25. $db->addConnection([
  26. 'driver' => 'sqlite',
  27. 'database' => ':memory:',
  28. ]);
  29. $db->addConnection([
  30. 'driver' => 'sqlite',
  31. 'database' => ':memory:',
  32. ], 'sqlite2');
  33. $db->addConnection([
  34. 'driver' => 'sqlite',
  35. 'database' => ':memory:',
  36. ], 'sqlite3');
  37. $db->setAsGlobal();
  38. $container = new Container;
  39. $container->instance('db', $db->getDatabaseManager());
  40. Facade::setFacadeApplication($container);
  41. $this->migrator = new Migrator(
  42. $repository = new DatabaseMigrationRepository($db->getDatabaseManager(), 'migrations'),
  43. $db->getDatabaseManager(),
  44. new Filesystem
  45. );
  46. $output = m::mock(OutputStyle::class);
  47. $output->shouldReceive('writeln');
  48. $this->migrator->setOutput($output);
  49. if (! $repository->repositoryExists()) {
  50. $repository->createRepository();
  51. }
  52. $repository2 = new DatabaseMigrationRepository($db->getDatabaseManager(), 'migrations');
  53. $repository2->setSource('sqlite2');
  54. if (! $repository2->repositoryExists()) {
  55. $repository2->createRepository();
  56. }
  57. }
  58. protected function tearDown(): void
  59. {
  60. Facade::clearResolvedInstances();
  61. Facade::setFacadeApplication(null);
  62. }
  63. public function testBasicMigrationOfSingleFolder()
  64. {
  65. $ran = $this->migrator->run([__DIR__.'/migrations/one']);
  66. $this->assertTrue($this->db->schema()->hasTable('users'));
  67. $this->assertTrue($this->db->schema()->hasTable('password_resets'));
  68. $this->assertTrue(Str::contains($ran[0], 'users'));
  69. $this->assertTrue(Str::contains($ran[1], 'password_resets'));
  70. }
  71. public function testMigrationsDefaultConnectionCanBeChanged()
  72. {
  73. $ran = $this->migrator->usingConnection('sqlite2', function () {
  74. return $this->migrator->run([__DIR__.'/migrations/one'], ['database' => 'sqllite3']);
  75. });
  76. $this->assertFalse($this->db->schema()->hasTable('users'));
  77. $this->assertFalse($this->db->schema()->hasTable('password_resets'));
  78. $this->assertTrue($this->db->schema('sqlite2')->hasTable('users'));
  79. $this->assertTrue($this->db->schema('sqlite2')->hasTable('password_resets'));
  80. $this->assertFalse($this->db->schema('sqlite3')->hasTable('users'));
  81. $this->assertFalse($this->db->schema('sqlite3')->hasTable('password_resets'));
  82. $this->assertTrue(Str::contains($ran[0], 'users'));
  83. $this->assertTrue(Str::contains($ran[1], 'password_resets'));
  84. }
  85. public function testMigrationsCanEachDefineConnection()
  86. {
  87. $ran = $this->migrator->run([__DIR__.'/migrations/connection_configured']);
  88. $this->assertFalse($this->db->schema()->hasTable('failed_jobs'));
  89. $this->assertFalse($this->db->schema()->hasTable('jobs'));
  90. $this->assertFalse($this->db->schema('sqlite2')->hasTable('failed_jobs'));
  91. $this->assertFalse($this->db->schema('sqlite2')->hasTable('jobs'));
  92. $this->assertTrue($this->db->schema('sqlite3')->hasTable('failed_jobs'));
  93. $this->assertTrue($this->db->schema('sqlite3')->hasTable('jobs'));
  94. $this->assertTrue(Str::contains($ran[0], 'failed_jobs'));
  95. $this->assertTrue(Str::contains($ran[1], 'jobs'));
  96. }
  97. public function testMigratorCannotChangeDefinedMigrationConnection()
  98. {
  99. $ran = $this->migrator->usingConnection('sqlite2', function () {
  100. return $this->migrator->run([__DIR__.'/migrations/connection_configured']);
  101. });
  102. $this->assertFalse($this->db->schema()->hasTable('failed_jobs'));
  103. $this->assertFalse($this->db->schema()->hasTable('jobs'));
  104. $this->assertFalse($this->db->schema('sqlite2')->hasTable('failed_jobs'));
  105. $this->assertFalse($this->db->schema('sqlite2')->hasTable('jobs'));
  106. $this->assertTrue($this->db->schema('sqlite3')->hasTable('failed_jobs'));
  107. $this->assertTrue($this->db->schema('sqlite3')->hasTable('jobs'));
  108. $this->assertTrue(Str::contains($ran[0], 'failed_jobs'));
  109. $this->assertTrue(Str::contains($ran[1], 'jobs'));
  110. }
  111. public function testMigrationsCanBeRolledBack()
  112. {
  113. $this->migrator->run([__DIR__.'/migrations/one']);
  114. $this->assertTrue($this->db->schema()->hasTable('users'));
  115. $this->assertTrue($this->db->schema()->hasTable('password_resets'));
  116. $rolledBack = $this->migrator->rollback([__DIR__.'/migrations/one']);
  117. $this->assertFalse($this->db->schema()->hasTable('users'));
  118. $this->assertFalse($this->db->schema()->hasTable('password_resets'));
  119. $this->assertTrue(Str::contains($rolledBack[0], 'password_resets'));
  120. $this->assertTrue(Str::contains($rolledBack[1], 'users'));
  121. }
  122. public function testMigrationsCanBeReset()
  123. {
  124. $this->migrator->run([__DIR__.'/migrations/one']);
  125. $this->assertTrue($this->db->schema()->hasTable('users'));
  126. $this->assertTrue($this->db->schema()->hasTable('password_resets'));
  127. $rolledBack = $this->migrator->reset([__DIR__.'/migrations/one']);
  128. $this->assertFalse($this->db->schema()->hasTable('users'));
  129. $this->assertFalse($this->db->schema()->hasTable('password_resets'));
  130. $this->assertTrue(Str::contains($rolledBack[0], 'password_resets'));
  131. $this->assertTrue(Str::contains($rolledBack[1], 'users'));
  132. }
  133. public function testNoErrorIsThrownWhenNoOutstandingMigrationsExist()
  134. {
  135. $this->migrator->run([__DIR__.'/migrations/one']);
  136. $this->assertTrue($this->db->schema()->hasTable('users'));
  137. $this->assertTrue($this->db->schema()->hasTable('password_resets'));
  138. $this->migrator->run([__DIR__.'/migrations/one']);
  139. }
  140. public function testNoErrorIsThrownWhenNothingToRollback()
  141. {
  142. $this->migrator->run([__DIR__.'/migrations/one']);
  143. $this->assertTrue($this->db->schema()->hasTable('users'));
  144. $this->assertTrue($this->db->schema()->hasTable('password_resets'));
  145. $this->migrator->rollback([__DIR__.'/migrations/one']);
  146. $this->assertFalse($this->db->schema()->hasTable('users'));
  147. $this->assertFalse($this->db->schema()->hasTable('password_resets'));
  148. $this->migrator->rollback([__DIR__.'/migrations/one']);
  149. }
  150. public function testMigrationsCanRunAcrossMultiplePaths()
  151. {
  152. $this->migrator->run([__DIR__.'/migrations/one', __DIR__.'/migrations/two']);
  153. $this->assertTrue($this->db->schema()->hasTable('users'));
  154. $this->assertTrue($this->db->schema()->hasTable('password_resets'));
  155. $this->assertTrue($this->db->schema()->hasTable('flights'));
  156. }
  157. public function testMigrationsCanBeRolledBackAcrossMultiplePaths()
  158. {
  159. $this->migrator->run([__DIR__.'/migrations/one', __DIR__.'/migrations/two']);
  160. $this->assertTrue($this->db->schema()->hasTable('users'));
  161. $this->assertTrue($this->db->schema()->hasTable('password_resets'));
  162. $this->assertTrue($this->db->schema()->hasTable('flights'));
  163. $this->migrator->rollback([__DIR__.'/migrations/one', __DIR__.'/migrations/two']);
  164. $this->assertFalse($this->db->schema()->hasTable('users'));
  165. $this->assertFalse($this->db->schema()->hasTable('password_resets'));
  166. $this->assertFalse($this->db->schema()->hasTable('flights'));
  167. }
  168. public function testMigrationsCanBeResetAcrossMultiplePaths()
  169. {
  170. $this->migrator->run([__DIR__.'/migrations/one', __DIR__.'/migrations/two']);
  171. $this->assertTrue($this->db->schema()->hasTable('users'));
  172. $this->assertTrue($this->db->schema()->hasTable('password_resets'));
  173. $this->assertTrue($this->db->schema()->hasTable('flights'));
  174. $this->migrator->reset([__DIR__.'/migrations/one', __DIR__.'/migrations/two']);
  175. $this->assertFalse($this->db->schema()->hasTable('users'));
  176. $this->assertFalse($this->db->schema()->hasTable('password_resets'));
  177. $this->assertFalse($this->db->schema()->hasTable('flights'));
  178. }
  179. public function testMigrationsCanBeProperlySortedAcrossMultiplePaths()
  180. {
  181. $paths = [__DIR__.'/migrations/multi_path/vendor', __DIR__.'/migrations/multi_path/app'];
  182. $migrationsFilesFullPaths = array_values($this->migrator->getMigrationFiles($paths));
  183. $expected = [
  184. __DIR__.'/migrations/multi_path/app/2016_01_01_000000_create_users_table.php', // This file was not created on the "vendor" directory on purpose
  185. __DIR__.'/migrations/multi_path/vendor/2016_01_01_200000_create_flights_table.php', // This file was not created on the "app" directory on purpose
  186. __DIR__.'/migrations/multi_path/app/2019_08_08_000001_rename_table_one.php',
  187. __DIR__.'/migrations/multi_path/app/2019_08_08_000002_rename_table_two.php',
  188. __DIR__.'/migrations/multi_path/app/2019_08_08_000003_rename_table_three.php',
  189. __DIR__.'/migrations/multi_path/app/2019_08_08_000004_rename_table_four.php',
  190. __DIR__.'/migrations/multi_path/app/2019_08_08_000005_create_table_one.php',
  191. __DIR__.'/migrations/multi_path/app/2019_08_08_000006_create_table_two.php',
  192. __DIR__.'/migrations/multi_path/vendor/2019_08_08_000007_create_table_three.php', // This file was not created on the "app" directory on purpose
  193. __DIR__.'/migrations/multi_path/app/2019_08_08_000008_create_table_four.php',
  194. ];
  195. $this->assertEquals($expected, $migrationsFilesFullPaths);
  196. }
  197. public function testConnectionPriorToMigrationIsNotChangedAfterMigration()
  198. {
  199. $this->migrator->setConnection('default');
  200. $this->migrator->run([__DIR__.'/migrations/one'], ['database' => 'sqlite2']);
  201. $this->assertSame('default', $this->migrator->getConnection());
  202. }
  203. public function testConnectionPriorToMigrationIsNotChangedAfterRollback()
  204. {
  205. $this->migrator->setConnection('default');
  206. $this->migrator->run([__DIR__.'/migrations/one'], ['database' => 'sqlite2']);
  207. $this->migrator->rollback([__DIR__.'/migrations/one'], ['database' => 'sqlite2']);
  208. $this->assertSame('default', $this->migrator->getConnection());
  209. }
  210. public function testConnectionPriorToMigrationIsNotChangedWhenNoOutstandingMigrationsExist()
  211. {
  212. $this->migrator->setConnection('default');
  213. $this->migrator->run([__DIR__.'/migrations/one'], ['database' => 'sqlite2']);
  214. $this->migrator->setConnection('default');
  215. $this->migrator->run([__DIR__.'/migrations/one'], ['database' => 'sqlite2']);
  216. $this->assertSame('default', $this->migrator->getConnection());
  217. }
  218. public function testConnectionPriorToMigrationIsNotChangedWhenNothingToRollback()
  219. {
  220. $this->migrator->setConnection('default');
  221. $this->migrator->run([__DIR__.'/migrations/one'], ['database' => 'sqlite2']);
  222. $this->migrator->rollback([__DIR__.'/migrations/one'], ['database' => 'sqlite2']);
  223. $this->migrator->rollback([__DIR__.'/migrations/one'], ['database' => 'sqlite2']);
  224. $this->assertSame('default', $this->migrator->getConnection());
  225. }
  226. public function testConnectionPriorToMigrationIsNotChangedAfterMigrateReset()
  227. {
  228. $this->migrator->setConnection('default');
  229. $this->migrator->run([__DIR__.'/migrations/one'], ['database' => 'sqlite2']);
  230. $this->migrator->reset([__DIR__.'/migrations/one'], ['database' => 'sqlite2']);
  231. $this->assertSame('default', $this->migrator->getConnection());
  232. }
  233. }