Skip to content

Commit 12987c6

Browse files
SiroDiazSiroDiaz
committedJun 16, 2022
Added CLI app, migrate, rollback commands and refactor
·
1.00.1
1 parent 339d8ab commit 12987c6

33 files changed

+1247
-38
lines changed
 

‎.github/workflows/pipeline.yml

+14
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,14 @@
1+
name: "install dependencies"
2+
3+
on:
4+
push:
5+
branches:
6+
- master
7+
- develop
8+
9+
jobs:
10+
install:
11+
runs-on: ubuntu-22.04
12+
steps:
13+
- uses: actions/checkout@v3
14+
- name: "install composer dependencies"

‎.gitignore

+253-1
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,255 @@
1+
### Composer ###
2+
composer.phar
13
/vendor/
2-
/.vscode/
4+
5+
# Commit your application's lock file https://getcomposer.org/doc/01-basic-usage.md#commit-your-composer-lock-file-to-version-control
6+
# You may choose to ignore a library lock file http://getcomposer.org/doc/02-libraries.md#lock-file
37
composer.lock
8+
9+
### PHPUnit ###
10+
# Covers PHPUnit
11+
# Reference: https://phpunit.de/
12+
13+
# Generated files
14+
.phpunit.result.cache
15+
.phpunit.cache
16+
17+
# PHPUnit
18+
/app/phpunit.xml
19+
/phpunit.xml
20+
21+
# Build data
22+
/build/
23+
24+
### PhpStorm ###
25+
# Covers JetBrains IDEs: IntelliJ, RubyMine, PhpStorm, AppCode, PyCharm, CLion, Android Studio, WebStorm and Rider
26+
# Reference: https://intellij-support.jetbrains.com/hc/en-us/articles/206544839
27+
28+
# User-specific stuff
29+
.idea/**/workspace.xml
30+
.idea/**/tasks.xml
31+
.idea/**/usage.statistics.xml
32+
.idea/**/dictionaries
33+
.idea/**/shelf
34+
35+
# AWS User-specific
36+
.idea/**/aws.xml
37+
38+
# Generated files
39+
.idea/**/contentModel.xml
40+
41+
# Sensitive or high-churn files
42+
.idea/**/dataSources/
43+
.idea/**/dataSources.ids
44+
.idea/**/dataSources.local.xml
45+
.idea/**/sqlDataSources.xml
46+
.idea/**/dynamic.xml
47+
.idea/**/uiDesigner.xml
48+
.idea/**/dbnavigator.xml
49+
50+
# Gradle
51+
.idea/**/gradle.xml
52+
.idea/**/libraries
53+
54+
# Gradle and Maven with auto-import
55+
# When using Gradle or Maven with auto-import, you should exclude module files,
56+
# since they will be recreated, and may cause churn. Uncomment if using
57+
# auto-import.
58+
# .idea/artifacts
59+
# .idea/compiler.xml
60+
# .idea/jarRepositories.xml
61+
# .idea/modules.xml
62+
# .idea/*.iml
63+
# .idea/modules
64+
# *.iml
65+
# *.ipr
66+
67+
# CMake
68+
cmake-build-*/
69+
70+
# Mongo Explorer plugin
71+
.idea/**/mongoSettings.xml
72+
73+
# File-based project format
74+
*.iws
75+
76+
# IntelliJ
77+
out/
78+
79+
# mpeltonen/sbt-idea plugin
80+
.idea_modules/
81+
82+
# JIRA plugin
83+
atlassian-ide-plugin.xml
84+
85+
# Cursive Clojure plugin
86+
.idea/replstate.xml
87+
88+
# SonarLint plugin
89+
.idea/sonarlint/
90+
91+
# Crashlytics plugin (for Android Studio and IntelliJ)
92+
com_crashlytics_export_strings.xml
93+
crashlytics.properties
94+
crashlytics-build.properties
95+
fabric.properties
96+
97+
# Editor-based Rest Client
98+
.idea/httpRequests
99+
100+
# Android studio 3.1+ serialized cache file
101+
.idea/caches/build_file_checksums.ser
102+
103+
### PhpStorm Patch ###
104+
# Comment Reason: https://github.com/joeblau/gitignore.io/issues/186#issuecomment-215987721
105+
106+
# *.iml
107+
# modules.xml
108+
# .idea/misc.xml
109+
# *.ipr
110+
111+
# Sonarlint plugin
112+
# https://plugins.jetbrains.com/plugin/7973-sonarlint
113+
.idea/**/sonarlint/
114+
115+
# SonarQube Plugin
116+
# https://plugins.jetbrains.com/plugin/7238-sonarqube-community-plugin
117+
.idea/**/sonarIssues.xml
118+
119+
# Markdown Navigator plugin
120+
# https://plugins.jetbrains.com/plugin/7896-markdown-navigator-enhanced
121+
.idea/**/markdown-navigator.xml
122+
.idea/**/markdown-navigator-enh.xml
123+
.idea/**/markdown-navigator/
124+
125+
# Cache file creation bug
126+
# See https://youtrack.jetbrains.com/issue/JBR-2257
127+
.idea/$CACHE_FILE$
128+
129+
# CodeStream plugin
130+
# https://plugins.jetbrains.com/plugin/12206-codestream
131+
.idea/codestream.xml
132+
133+
# Azure Toolkit for IntelliJ plugin
134+
# https://plugins.jetbrains.com/plugin/8053-azure-toolkit-for-intellij
135+
.idea/**/azureSettings.xml
136+
137+
### Vim ###
138+
# Swap
139+
[._]*.s[a-v][a-z]
140+
!*.svg # comment out if you don't need vector files
141+
[._]*.sw[a-p]
142+
[._]s[a-rt-v][a-z]
143+
[._]ss[a-gi-z]
144+
[._]sw[a-p]
145+
146+
# Session
147+
Session.vim
148+
Sessionx.vim
149+
150+
# Temporary
151+
.netrwhist
152+
*~
153+
# Auto-generated tag files
154+
tags
155+
# Persistent undo
156+
[._]*.un~
157+
158+
### VisualStudioCode ###
159+
.vscode/*
160+
!.vscode/settings.json
161+
!.vscode/tasks.json
162+
!.vscode/launch.json
163+
!.vscode/extensions.json
164+
!.vscode/*.code-snippets
165+
166+
# Local History for Visual Studio Code
167+
.history/
168+
169+
# Built Visual Studio Code Extensions
170+
*.vsix
171+
172+
### VisualStudioCode Patch ###
173+
# Ignore all local history of files
174+
.history
175+
.ionide
176+
177+
# Support for Project snippet scope
178+
.vscode/*.code-snippets
179+
180+
# Ignore code-workspaces
181+
*.code-workspace
182+
183+
### Linux ###
184+
*~
185+
186+
# temporary files which can be created if a process still has a handle open of a deleted file
187+
.fuse_hidden*
188+
189+
# KDE directory preferences
190+
.directory
191+
192+
# Linux trash folder which might appear on any partition or disk
193+
.Trash-*
194+
195+
# .nfs files are created when an open file is removed but is still being accessed
196+
.nfs*
197+
198+
### macOS ###
199+
# General
200+
.DS_Store
201+
.AppleDouble
202+
.LSOverride
203+
204+
# Icon must end with two \r
205+
Icon
206+
207+
208+
# Thumbnails
209+
._*
210+
211+
# Files that might appear in the root of a volume
212+
.DocumentRevisions-V100
213+
.fseventsd
214+
.Spotlight-V100
215+
.TemporaryItems
216+
.Trashes
217+
.VolumeIcon.icns
218+
.com.apple.timemachine.donotpresent
219+
220+
# Directories potentially created on remote AFP share
221+
.AppleDB
222+
.AppleDesktop
223+
Network Trash Folder
224+
Temporary Items
225+
.apdisk
226+
227+
### macOS Patch ###
228+
# iCloud generated files
229+
*.icloud
230+
231+
### Windows ###
232+
# Windows thumbnail cache files
233+
Thumbs.db
234+
Thumbs.db:encryptable
235+
ehthumbs.db
236+
ehthumbs_vista.db
237+
238+
# Dump file
239+
*.stackdump
240+
241+
# Folder config file
242+
[Dd]esktop.ini
243+
244+
# Recycle Bin used on file shares
245+
$RECYCLE.BIN/
246+
247+
# Windows Installer files
248+
*.cab
249+
*.msi
250+
*.msix
251+
*.msm
252+
*.msp
253+
254+
# Windows shortcuts
255+
*.lnk

‎.vscode/settings.json

+11
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,11 @@
1+
{
2+
"sqltools.connections": [
3+
{
4+
"previewLimit": 50,
5+
"driver": "SQLite",
6+
"name": "playground",
7+
"database": "${workspaceFolder:manticore-migration}/examples/database/playground.sqlite"
8+
}
9+
],
10+
"sqltools.useNodeRuntime": true
11+
}

‎README.md

+11-7
Original file line numberDiff line numberDiff line change
@@ -2,16 +2,20 @@
22
Manticoresearch migration tool. Keep updated your index schemas up to date programmatically in your application.
33

44
## project progress and roadmap
5+
- [ ] Add a logger implementation
56
- [ ] Add command line interface feature
6-
- [ ] Executable script (bin/manticore-migration)
7+
- [x] Executable script (bin/manticore-migration)
78
- [ ] Add commands
89
- [ ] list
9-
- [ ] list:all
10-
- [ ] list:pending
11-
- [ ] list:migrated
12-
- [ ] migrate
13-
- [ ] rollback
10+
- [ ] migration:list:pending
11+
- [ ] migration:list:migrated
12+
- [x] migrate
13+
- [x] rollback
14+
- [ ] rollback with --steps
15+
- [x] fresh
1416
- [ ] refresh
17+
- [ ] refresh with --steps
18+
- [ ] reset
1519
- [ ] status
1620
- [ ] help
1721
- [ ] Add drivers to support multiple DBs engines dialects
@@ -23,7 +27,7 @@ Manticoresearch migration tool. Keep updated your index schemas up to date progr
2327
- [ ] Add tests
2428
## Installation
2529

26-
```bash composer require manticore-migration```
30+
```composer require manticore-migration```
2731

2832
## Usage
2933

‎app/cli.php

+14
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,14 @@
1+
<?php
2+
3+
require __DIR__ . '/../vendor/autoload.php';
4+
5+
use Symfony\Component\Console\Application;
6+
7+
$application = new Application();
8+
9+
// register commands
10+
$application->add(new \SiroDiaz\ManticoreMigration\Command\MigrateCommand());
11+
$application->add(new \SiroDiaz\ManticoreMigration\Command\RollbackCommand());
12+
$application->add(new \SiroDiaz\ManticoreMigration\Command\ListPendingCommand());
13+
$application->add(new \SiroDiaz\ManticoreMigration\Command\ListMigratedCommand());
14+
$application->add(new \SiroDiaz\ManticoreMigration\Command\MakeMigrationCommand());

‎bin/manticore-migrator

+6
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,6 @@
1+
#!/usr/bin/env php
2+
<?php
3+
4+
require __DIR__ . '/../app/cli.php';
5+
6+
$application->run();

‎bin/manticore-migrator.bat

+41
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,41 @@
1+
@echo off
2+
3+
rem This script will do the following:
4+
rem - check for PHP_COMMAND env, if found, use it.
5+
rem - if not found detect php, if found use it, otherwise err and terminate
6+
7+
if "%OS%"=="Windows_NT" @setlocal
8+
9+
rem %~dp0 is expanded pathname of the current script under NT
10+
set DEFAULT_MANTICORE_MIGRATOR_HOME=%~dp0
11+
12+
goto init
13+
goto cleanup
14+
15+
:init
16+
17+
if "%MANTICORE_MIGRATOR_HOME%" == "" set MANTICORE_MIGRATOR_HOME=%DEFAULT_MANTICORE_MIGRATOR_HOME%
18+
set DEFAULT_MANTICORE_MIGRATOR_HOME=
19+
20+
if "%PHP_COMMAND%" == "" goto no_phpcommand
21+
22+
goto run
23+
goto cleanup
24+
25+
:run
26+
"%PHP_COMMAND%" -d html_errors=off -qC "%MANTICORE_MIGRATOR_HOME%manticore_migrator.bat" %*
27+
goto cleanup
28+
29+
:no_phpcommand
30+
rem PHP_COMMAND environment variable not found, assuming php.exe is on path.
31+
set PHP_COMMAND=php.exe
32+
goto init
33+
34+
:err_home
35+
echo ERROR: Environment var MANTICORE_MIGRATOR_HOME not set. Please point this
36+
echo variable to your local MANTICORE_MIGRATOR installation!
37+
goto cleanup
38+
39+
:cleanup
40+
if "%OS%"=="Windows_NT" @endlocal
41+
rem pause

‎composer.json

+3-1
Original file line numberDiff line numberDiff line change
@@ -22,12 +22,14 @@
2222
"require": {
2323
"php": ">=7.3.0",
2424
"manticoresoftware/manticoresearch-php": "^1.8",
25-
"nyholm/dsn": "^2.0"
25+
"nyholm/dsn": "^2.0",
26+
"symfony/console": "^5.4.9"
2627
},
2728
"require-dev": {
2829
"phpunit/phpunit": "^9.0",
2930
"phpstan/phpstan": "^1.6"
3031
},
32+
"bin": ["bin/manticore-migrator"],
3133
"config": {
3234
"sort-packages": true
3335
},

‎docker-compose.all.yml

+63
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,63 @@
1+
version: '3'
2+
3+
services:
4+
manticore:
5+
container_name: manticoresearch
6+
image: manticoresearch/manticore
7+
restart: always
8+
ports:
9+
- 9306:9306
10+
- 9308:9308
11+
volumes:
12+
- manticore_dev_data:/var/lib/manticore
13+
networks:
14+
- manticore_network
15+
16+
postgresql:
17+
container_name: postgresql
18+
image: postgres:14.3-alpine
19+
restart: always
20+
ports:
21+
- 5432:5432
22+
environment:
23+
POSTGRES_USER: manticore
24+
POSTGRES_PASSWORD: manticore
25+
POSTGRES_DB: manticore
26+
PGDATA: '/var/lib/postgresql/data/pgdata'
27+
volumes:
28+
- pgdata_manticore_data:/var/lib/postgresql/data
29+
networks:
30+
- manticore_network
31+
32+
mysql:
33+
container_name: mysql
34+
image: mysql:8-debian
35+
restart: always
36+
ports:
37+
- 3306:3306
38+
environment:
39+
MYSQL_ROOT_PASSWORD: "manticore"
40+
MYSQL_DATABASE: "manticore"
41+
MYSQL_USER: "manticore"
42+
MYSQL_PASSWORD: "manticore"
43+
volumes:
44+
- mysql_manticore_data:/var/lib/mysql
45+
networks:
46+
- manticore_network
47+
48+
adminer:
49+
image: adminer
50+
restart: always
51+
ports:
52+
- 8080:8080
53+
networks:
54+
- manticore_network
55+
56+
volumes:
57+
manticore_dev_data:
58+
pgdata_manticore_data:
59+
mysql_manticore_data:
60+
61+
networks:
62+
manticore_network:
63+
driver: bridge

‎docker-compose.mysql.yml

+46
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,46 @@
1+
version: '3'
2+
3+
services:
4+
manticore:
5+
container_name: manticore
6+
image: manticoresearch/manticore
7+
restart: always
8+
ports:
9+
- 9306:9306
10+
- 9308:9308
11+
volumes:
12+
- manticore_example_data:/var/lib/manticore
13+
networks:
14+
- manticore_network
15+
16+
mysql:
17+
container_name: mysql
18+
image: mysql:8-debian
19+
restart: always
20+
ports:
21+
- 3306:3306
22+
environment:
23+
MYSQL_ROOT_PASSWORD: "manticore"
24+
MYSQL_DATABASE: "manticore"
25+
MYSQL_USER: "manticore"
26+
MYSQL_PASSWORD: "manticore"
27+
volumes:
28+
- mysql_manticore_data:/var/lib/mysql
29+
networks:
30+
- manticore_network
31+
32+
adminer:
33+
image: adminer
34+
restart: always
35+
ports:
36+
- 8080:8080
37+
networks:
38+
- manticore_network
39+
40+
volumes:
41+
manticore_example_data:
42+
mysql_manticore_data:
43+
44+
networks:
45+
manticore_network:
46+
driver: bridge

‎docker-compose.pgsql.yml

+46
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,46 @@
1+
version: '3'
2+
3+
services:
4+
manticore:
5+
container_name: manticore
6+
image: manticoresearch/manticore
7+
restart: always
8+
ports:
9+
- 9306:9306
10+
- 9308:9308
11+
volumes:
12+
- manticore_example_data:/var/lib/manticore
13+
networks:
14+
- manticore_network
15+
16+
mysql:
17+
container_name: mysql
18+
image: postgres:14.3-alpine
19+
restart: always
20+
ports:
21+
- 3306:3306
22+
environment:
23+
POSTGRES_USER: manticore
24+
POSTGRES_PASSWORD: manticore
25+
POSTGRES_DB: manticore
26+
PGDATA: '/var/lib/postgresql/data/pgdata'
27+
volumes:
28+
- pgdata_manticore_data:/var/lib/postgresql/data
29+
networks:
30+
- manticore_network
31+
32+
adminer:
33+
image: adminer
34+
restart: always
35+
ports:
36+
- 8080:8080
37+
networks:
38+
- manticore_network
39+
40+
volumes:
41+
manticore_example_data:
42+
pgdata_manticore_data:
43+
44+
networks:
45+
manticore_network:
46+
driver: bridge

‎docker-compose.yml

+15
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,15 @@
1+
version: '3'
2+
3+
services:
4+
manticore:
5+
container_name: manticore
6+
image: manticoresearch/manticore
7+
restart: always
8+
ports:
9+
- 9306:9306
10+
- 9308:9308
11+
volumes:
12+
- manticore_example_data:/var/lib/manticore
13+
14+
volumes:
15+
manticore_example_data:

‎examples/config.php

+26-7
Original file line numberDiff line numberDiff line change
@@ -1,13 +1,32 @@
11
<?php
22

33
return [
4-
'connection' => [
5-
'driver' => 'sqlite',
6-
'database' => __DIR__ . '/database/playground.sqlite',
7-
'host' => '',
8-
'port' => '',
9-
'user' => '',
10-
'password' => '',
4+
'connection' => 'sqlite',
5+
'connections' => [
6+
'sqlite' => [
7+
'driver' => 'sqlite',
8+
'database' => __DIR__ . '/database/playground.sqlite',
9+
'host' => '',
10+
'port' => '',
11+
'user' => '',
12+
'password' => '',
13+
],
14+
'mysql' => [
15+
'driver' => 'mysql',
16+
'database' => 'manticore',
17+
'host' => '127.0.0.1',
18+
'port' => 3306,
19+
'user' => 'manticore',
20+
'password' => 'manticore',
21+
],
22+
'pgsql' => [
23+
'driver' => 'pgsql',
24+
'database' => 'manticore',
25+
'host' => '127.0.0.1',
26+
'port' => 5432,
27+
'user' => 'manticore',
28+
'password' => 'manticore',
29+
]
1130
],
1231

1332
'table_prefix' => 'manticore_',

‎examples/database/playground.sqlite

0 Bytes
Binary file not shown.

‎examples/index.php

+1-10
Original file line numberDiff line numberDiff line change
@@ -111,15 +111,7 @@ function listMigrations()
111111

112112
function migrate() {
113113
$configuration = require __DIR__ .'/config.php';
114-
// check if the migration table exists
115-
// $migrationTable = new MigrationTable($dbConn, $configuration['table_prefix'], $configuration['migration_table']);
116-
// // if not, create it
117-
// $migrationTable->exists() === false ?? $migrationTable->create();
118-
// // if it exists, check latest migration version
119-
// $latestMigration = $migrationTable->getLatestMigrations();
120-
// if the latest migration version is the same as the current version, do nothing
121-
// if the latest migration version is different, run the migrations
122-
//$migrations = (new Loader())->load($configuration['migrations_path']);
114+
123115
$dbConnection = new DatabaseConnection(
124116
DatabaseConfiguration::fromArray($configuration['connection'])
125117
);
@@ -165,7 +157,6 @@ function rollback($steps = 1) {
165157
->migrationTable($migrationTable);
166158

167159
$director->undoMigrations($steps);
168-
169160
}
170161

171162
function refresh() {

‎examples/manticore_migrations/2022_01_09_155021_create_users_index.php

+1-1
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@ class CreateUsersIndex extends Migration
1414
* @return void
1515
*/
1616
public function up(): void {
17-
$this->runner->execute('CREATE TABLE users (id bigint, name text indexed, username text stored, biography text, birthdate timestamp)');
17+
$this->runner->execute('CREATE TABLE users (id bigint, name text, username text, biography text, birthdate timestamp)');
1818
$this->indexer->index('users', 'SELECT id, name, username, biography, birthdate FROM users');
1919
}
2020

‎examples/manticore_migrations/2022_01_09_155022_create_products_index.php

+5-5
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,6 @@
11
<?php
22

3-
use SiroDiaz\ManticoreMigration\Indexer\Indexer;
43
use SiroDiaz\ManticoreMigration\Migration;
5-
use SiroDiaz\ManticoreMigration\Runner\ManticoreRunner;
64

75
class CreateProductsIndex extends Migration
86
{
@@ -12,8 +10,9 @@ class CreateProductsIndex extends Migration
1210
*
1311
* @return void
1412
*/
15-
public function up(): void {
16-
$this->runner->execute('CREATE TABLE products (id bigint, seller_id bigint, title text stored, description text stored, price float)');
13+
public function up(): void
14+
{
15+
$this->runner->execute('CREATE TABLE products (id bigint, seller_id bigint, title text, description text, price float)');
1716
$this->indexer->index('products', 'SELECT id, seller_id, name as title, description, price FROM products');
1817
}
1918

@@ -22,7 +21,8 @@ public function up(): void {
2221
*
2322
* @return void
2423
*/
25-
public function down(): void {
24+
public function down(): void
25+
{
2626
$this->runner->execute('DROP TABLE products');
2727
}
2828
}

‎examples/schema_data.sql

+3-3
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,7 @@ CREATE INDEX IF NOT EXISTS users_index_birthdate ON users (birthdate);
1313
INSERT VALUES INTO users (id, name, username, biography, birthdate)
1414
VALUES (1, 'John Doe', 'jdoe', '', '1980-01-01'), (2, 'Jane Doe', 'jdoe2', '', '1980-01-01'),
1515
(3, 'John Smith', 'jsmith', '', '1980-01-01'), (4, 'Jane Smith', 'jsmith2', '', '1980-01-01'),
16-
(4, 'Jane Smith', 'jsmith2', '', '1980-01-01'), (5, 'John Smith', 'jsmith3', '', '1980-01-01');
16+
(5, 'John Smith', 'jsmith3', '', '1980-01-01');
1717

1818

1919
CREATE TABLE IF NOT EXISTS products (
@@ -28,7 +28,7 @@ CREATE TABLE IF NOT EXISTS products (
2828

2929
INSERT INTO products (id, seller_id, name, description, price)
3030
VALUES
31-
(1, 1, 'AMD Ryzen 5 2600', '', 2999.99),
32-
(2, 1, 'Intel Core i7-7700K', '', 2999.99),
31+
(1, 1, 'AMD Ryzen 5 2600', '', 299.99),
32+
(2, 1, 'Intel Core i7-7700K', '', 299.99),
3333
(3, 2, 'Raspberry Pi 3', '', 29.99),
3434
(4, 1, 'Raspberry Pi 4', '', 39.99);

‎src/Command/AbstractCommand.php

+65
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,65 @@
1+
<?php
2+
3+
namespace SiroDiaz\ManticoreMigration\Command;
4+
5+
use Symfony\Component\Console\Command\Command;
6+
use Symfony\Component\Console\Exception\MissingInputException;
7+
use Symfony\Component\Console\Input\InputInterface;
8+
use Symfony\Component\Console\Input\InputOption;
9+
use Symfony\Component\Console\Output\OutputInterface;
10+
11+
class AbstractCommand extends Command
12+
{
13+
protected static $defaultName = 'manticore';
14+
15+
/**
16+
* @var array
17+
*/
18+
protected $configuration;
19+
20+
/**
21+
* @var string
22+
*/
23+
protected $connection;
24+
25+
protected function configure()
26+
{
27+
$this->addOption('--connection', null, InputOption::VALUE_OPTIONAL, 'Specify the database connection to use');
28+
$this->addOption('--configuration', '-c', InputOption::VALUE_REQUIRED, 'The configuration file to load');
29+
/** @todo */
30+
// $this->addOption('--parser', '-p', InputOption::VALUE_REQUIRED, 'Parser used to read the config file. Defaults to PHP');
31+
$this->addOption('--no-info', null, InputOption::VALUE_NONE, 'Hides all debug information');
32+
33+
$this->addOption('--no-info', null, InputOption::VALUE_NONE, 'Hides all debug information');
34+
}
35+
36+
protected function validateConfigurationOption($configuration)
37+
{
38+
if ($configuration === null) {
39+
throw new MissingInputException('<error>You must specify a configuration file</error>');
40+
}
41+
}
42+
43+
protected function requireConfigFile($configuration)
44+
{
45+
$this->configuration = require $configuration;
46+
}
47+
48+
protected function execute(InputInterface $input, OutputInterface $output): int
49+
{
50+
try {
51+
$this->validateConfigurationOption($input->getOption('configuration'));
52+
} catch (MissingInputException $exception) {
53+
$output->writeln($exception->getMessage());
54+
55+
return Command::INVALID;
56+
}
57+
58+
$this->requireConfigFile($input->getOption('configuration'));
59+
60+
$this->connection = $input->getOption('connection') ?? $this->configuration['connection'];
61+
62+
return Command::SUCCESS;
63+
}
64+
65+
}

‎src/Command/ListMigratedCommand.php

+74
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,74 @@
1+
<?php
2+
3+
namespace SiroDiaz\ManticoreMigration\Command;
4+
5+
use SiroDiaz\ManticoreMigration\Manticore\ManticoreConnection;
6+
use SiroDiaz\ManticoreMigration\MigrationDirector;
7+
use SiroDiaz\ManticoreMigration\Storage\DatabaseConfiguration;
8+
use SiroDiaz\ManticoreMigration\Storage\DatabaseConnection;
9+
use SiroDiaz\ManticoreMigration\Storage\MigrationTable;
10+
use Symfony\Component\Console\Command\Command;
11+
use Symfony\Component\Console\Input\InputArgument;
12+
use Symfony\Component\Console\Input\InputInterface;
13+
use Symfony\Component\Console\Input\InputOption;
14+
use Symfony\Component\Console\Output\OutputInterface;
15+
16+
class ListMigratedCommand extends Command
17+
{
18+
protected static $defaultName = 'migration:list:migrated';
19+
20+
/**
21+
* {@inheritDoc}
22+
*
23+
* @return void
24+
*/
25+
protected function configure()
26+
{
27+
// parent::configure();
28+
$this->addOption('--configuration', '-c', InputOption::VALUE_REQUIRED, 'The configuration file to load');
29+
// $this->addOption('--parser', '-p', InputOption::VALUE_REQUIRED, 'Parser used to read the config file. Defaults to PHP');
30+
$this->addOption('--no-info', null, InputOption::VALUE_NONE, 'Hides all debug information');
31+
32+
$this->addOption('--no-info', null, InputOption::VALUE_NONE, 'Hides all debug information');
33+
$this->setDescription('Lists Manticoresearch migrations applied')
34+
->setHelp(sprintf(
35+
'%sLists Manticoresearch migrations applied%s',
36+
PHP_EOL,
37+
PHP_EOL
38+
));
39+
}
40+
41+
protected function execute(InputInterface $input, OutputInterface $output): int
42+
{
43+
if ($input->getOption('configuration') === null) {
44+
$output->writeln('<error>You must specify a configuration file</error>');
45+
46+
return Command::INVALID;
47+
}
48+
49+
$configuration = require $input->getOption('configuration');
50+
51+
$dbConnection = new DatabaseConnection(
52+
DatabaseConfiguration::fromArray($configuration['connection'])
53+
);
54+
55+
$manticoreConnection = new ManticoreConnection(
56+
$configuration['manticore_connection']['host'],
57+
$configuration['manticore_connection']['port'],
58+
);
59+
60+
$migrationTable = new MigrationTable($dbConnection, $configuration['table_prefix'], $configuration['migration_table']);
61+
62+
$director = new MigrationDirector();
63+
$director
64+
->dbConnection($dbConnection)
65+
->manticoreConnection($manticoreConnection)
66+
->migrationsPath($configuration['migrations_path'])
67+
->migrationTable($migrationTable);
68+
69+
$director->undoMigrations($input->getOption('steps'));
70+
71+
return Command::SUCCESS;
72+
}
73+
74+
}

‎src/Command/ListPendingCommand.php

+76
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,76 @@
1+
<?php
2+
3+
namespace SiroDiaz\ManticoreMigration\Command;
4+
5+
use SiroDiaz\ManticoreMigration\Manticore\ManticoreConnection;
6+
use SiroDiaz\ManticoreMigration\MigrationDirector;
7+
use SiroDiaz\ManticoreMigration\Storage\DatabaseConfiguration;
8+
use SiroDiaz\ManticoreMigration\Storage\DatabaseConnection;
9+
use SiroDiaz\ManticoreMigration\Storage\MigrationTable;
10+
use Symfony\Component\Console\Command\Command;
11+
use Symfony\Component\Console\Input\InputArgument;
12+
use Symfony\Component\Console\Input\InputInterface;
13+
use Symfony\Component\Console\Input\InputOption;
14+
use Symfony\Component\Console\Output\OutputInterface;
15+
16+
class ListPendingCommand extends AbstractCommand
17+
{
18+
protected static $defaultName = 'migration:list:pending';
19+
20+
/**
21+
* {@inheritDoc}
22+
*
23+
* @return void
24+
*/
25+
protected function configure()
26+
{
27+
parent::configure();
28+
29+
$this->setDescription('Rollback a migration to a previous version')
30+
->setHelp(sprintf(
31+
'%sLists Manticoresearch pending migrations%s',
32+
PHP_EOL,
33+
PHP_EOL
34+
));
35+
}
36+
37+
protected function execute(InputInterface $input, OutputInterface $output): int
38+
{
39+
if ($input->getOption('configuration') === null) {
40+
$output->writeln('<error>You must specify a configuration file</error>');
41+
42+
return Command::INVALID;
43+
}
44+
45+
$configuration = require $input->getOption('configuration');
46+
47+
$dbConnection = new DatabaseConnection(
48+
DatabaseConfiguration::fromArray($configuration['connection'])
49+
);
50+
51+
$manticoreConnection = new ManticoreConnection(
52+
$configuration['manticore_connection']['host'],
53+
$configuration['manticore_connection']['port'],
54+
);
55+
56+
$migrationTable = new MigrationTable($dbConnection, $configuration['table_prefix'], $configuration['migration_table']);
57+
58+
$director = new MigrationDirector();
59+
$director
60+
->dbConnection($dbConnection)
61+
->manticoreConnection($manticoreConnection)
62+
->migrationsPath($configuration['migrations_path'])
63+
->migrationTable($migrationTable);
64+
65+
$pendingMigrations = $director->getPendingMigrations();
66+
67+
if (count($pendingMigrations) > 0) {
68+
var_dump($pendingMigrations);
69+
} else {
70+
$output->writeln('<info>ManticoreSearch is up to date! no pending migrations</info>');
71+
}
72+
73+
return Command::SUCCESS;
74+
}
75+
76+
}

‎src/Command/MakeMigrationCommand.php

+74
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,74 @@
1+
<?php
2+
3+
namespace SiroDiaz\ManticoreMigration\Command;
4+
5+
use SiroDiaz\ManticoreMigration\Manticore\ManticoreConnection;
6+
use SiroDiaz\ManticoreMigration\MigrationDirector;
7+
use SiroDiaz\ManticoreMigration\Storage\DatabaseConfiguration;
8+
use SiroDiaz\ManticoreMigration\Storage\DatabaseConnection;
9+
use SiroDiaz\ManticoreMigration\Storage\MigrationTable;
10+
use Symfony\Component\Console\Command\Command;
11+
use Symfony\Component\Console\Input\InputArgument;
12+
use Symfony\Component\Console\Input\InputInterface;
13+
use Symfony\Component\Console\Input\InputOption;
14+
use Symfony\Component\Console\Output\OutputInterface;
15+
16+
class MakeMigrationCommand extends Command
17+
{
18+
protected static $defaultName = 'make:migration';
19+
20+
/**
21+
* {@inheritDoc}
22+
*
23+
* @return void
24+
*/
25+
protected function configure()
26+
{
27+
// parent::configure();
28+
$this->addOption('--configuration', '-c', InputOption::VALUE_REQUIRED, 'The configuration file to load');
29+
// $this->addOption('--parser', '-p', InputOption::VALUE_REQUIRED, 'Parser used to read the config file. Defaults to PHP');
30+
$this->addOption('--no-info', null, InputOption::VALUE_NONE, 'Hides all debug information');
31+
32+
$this->addOption('--no-info', null, InputOption::VALUE_NONE, 'Hides all debug information');
33+
$this->setDescription('Lists Manticoresearch migrations applied')
34+
->setHelp(sprintf(
35+
'%sLists Manticoresearch migrations applied%s',
36+
PHP_EOL,
37+
PHP_EOL
38+
));
39+
}
40+
41+
protected function execute(InputInterface $input, OutputInterface $output): int
42+
{
43+
if ($input->getOption('configuration') === null) {
44+
$output->writeln('<error>You must specify a configuration file</error>');
45+
46+
return Command::INVALID;
47+
}
48+
49+
$configuration = require $input->getOption('configuration');
50+
51+
$dbConnection = new DatabaseConnection(
52+
DatabaseConfiguration::fromArray($configuration['connection'])
53+
);
54+
55+
$manticoreConnection = new ManticoreConnection(
56+
$configuration['manticore_connection']['host'],
57+
$configuration['manticore_connection']['port'],
58+
);
59+
60+
$migrationTable = new MigrationTable($dbConnection, $configuration['table_prefix'], $configuration['migration_table']);
61+
62+
$director = new MigrationDirector();
63+
$director
64+
->dbConnection($dbConnection)
65+
->manticoreConnection($manticoreConnection)
66+
->migrationsPath($configuration['migrations_path'])
67+
->migrationTable($migrationTable);
68+
69+
$director->undoMigrations($input->getOption('steps'));
70+
71+
return Command::SUCCESS;
72+
}
73+
74+
}

‎src/Command/MigrateCommand.php

+89
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,89 @@
1+
<?php
2+
3+
namespace SiroDiaz\ManticoreMigration\Command;
4+
5+
use Exception;
6+
use SiroDiaz\ManticoreMigration\Manticore\ManticoreConnection;
7+
use SiroDiaz\ManticoreMigration\MigrationDirector;
8+
use SiroDiaz\ManticoreMigration\Storage\DatabaseConfiguration;
9+
use SiroDiaz\ManticoreMigration\Storage\DatabaseConnection;
10+
use SiroDiaz\ManticoreMigration\Storage\MigrationTable;
11+
use Symfony\Component\Console\Command\Command;
12+
use Symfony\Component\Console\Input\InputArgument;
13+
use Symfony\Component\Console\Input\InputInterface;
14+
use Symfony\Component\Console\Input\InputOption;
15+
use Symfony\Component\Console\Output\OutputInterface;
16+
17+
class MigrateCommand extends AbstractCommand
18+
{
19+
protected static $defaultName = 'migrate';
20+
21+
/**
22+
* {@inheritDoc}
23+
*
24+
* @return void
25+
*/
26+
protected function configure()
27+
{
28+
parent::configure();
29+
30+
$this->setDescription('Syncronizes ManticoreSearch with the migration files')
31+
->setHelp(sprintf(
32+
'%sRun pending Manticoresearch migrations%s',
33+
PHP_EOL,
34+
PHP_EOL
35+
));
36+
}
37+
38+
protected function execute(InputInterface $input, OutputInterface $output): int
39+
{
40+
$commandExitCode = parent::execute($input, $output);
41+
42+
if ($commandExitCode !== Command::SUCCESS) {
43+
return $commandExitCode;
44+
}
45+
46+
$dbConnection = new DatabaseConnection(
47+
DatabaseConfiguration::fromArray(
48+
$this->configuration['connections'][$this->connection]
49+
)
50+
);
51+
52+
$manticoreConnection = new ManticoreConnection(
53+
$this->configuration['manticore_connection']['host'],
54+
$this->configuration['manticore_connection']['port'],
55+
);
56+
57+
$migrationTable = new MigrationTable(
58+
$dbConnection,
59+
$this->configuration['table_prefix'],
60+
$this->configuration['migration_table'],
61+
);
62+
63+
$director = new MigrationDirector();
64+
65+
$director
66+
->dbConnection($dbConnection)
67+
->manticoreConnection($manticoreConnection)
68+
->migrationsPath($this->configuration['migrations_path'])
69+
->migrationTable($migrationTable);
70+
71+
if (!$migrationTable->exists()) {
72+
$output->writeln('<info>Migration table doesn\'t exist</info>');
73+
} elseif (!$director->hasPendingMigrations()) {
74+
$output->writeln('<info>No pending migrations</info>');
75+
return Command::SUCCESS;
76+
}
77+
78+
try {
79+
$director->migrate();
80+
} catch (Exception $exception) {
81+
$output->writeln($exception->getMessage());
82+
83+
return Command::FAILURE;
84+
}
85+
86+
return Command::SUCCESS;
87+
}
88+
89+
}

‎src/Command/RollbackCommand.php

+76
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,76 @@
1+
<?php
2+
3+
namespace SiroDiaz\ManticoreMigration\Command;
4+
5+
use SiroDiaz\ManticoreMigration\Manticore\ManticoreConnection;
6+
use SiroDiaz\ManticoreMigration\MigrationDirector;
7+
use SiroDiaz\ManticoreMigration\Storage\DatabaseConfiguration;
8+
use SiroDiaz\ManticoreMigration\Storage\DatabaseConnection;
9+
use SiroDiaz\ManticoreMigration\Storage\MigrationTable;
10+
use Symfony\Component\Console\Command\Command;
11+
use Symfony\Component\Console\Input\InputArgument;
12+
use Symfony\Component\Console\Input\InputInterface;
13+
use Symfony\Component\Console\Input\InputOption;
14+
use Symfony\Component\Console\Output\OutputInterface;
15+
16+
class RollbackCommand extends AbstractCommand
17+
{
18+
protected static $defaultName = 'rollback';
19+
20+
/**
21+
* {@inheritDoc}
22+
*
23+
* @return void
24+
*/
25+
protected function configure()
26+
{
27+
parent::configure();
28+
29+
$this->setDescription('Rollback a migration to a previous version')
30+
->setHelp(sprintf(
31+
'%sCreates a new Manticoresearch migration%s',
32+
PHP_EOL,
33+
PHP_EOL
34+
));
35+
36+
$this->addOption('--steps', null, InputOption::VALUE_OPTIONAL, 'Specify the number of versions to rollback', 1);
37+
}
38+
39+
protected function execute(InputInterface $input, OutputInterface $output): int
40+
{
41+
$commandExitCode = parent::execute($input, $output);
42+
43+
if ($commandExitCode !== Command::SUCCESS) {
44+
return $commandExitCode;
45+
}
46+
47+
$dbConnection = new DatabaseConnection(
48+
DatabaseConfiguration::fromArray(
49+
$this->configuration['connections'][$this->connection]
50+
),
51+
);
52+
53+
$manticoreConnection = new ManticoreConnection(
54+
$this->configuration['manticore_connection']['host'],
55+
$this->configuration['manticore_connection']['port'],
56+
);
57+
58+
$migrationTable = new MigrationTable(
59+
$dbConnection,
60+
$this->configuration['table_prefix'],
61+
$this->configuration['migration_table']
62+
);
63+
64+
$director = new MigrationDirector();
65+
$director
66+
->dbConnection($dbConnection)
67+
->manticoreConnection($manticoreConnection)
68+
->migrationsPath($this->configuration['migrations_path'])
69+
->migrationTable($migrationTable);
70+
71+
$director->undoMigrations($input->getOption('steps'));
72+
73+
return Command::SUCCESS;
74+
}
75+
76+
}

‎src/MigrationCreator.php

+85
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,85 @@
1+
<?php
2+
3+
namespace SiroDiaz\ManticoreMigration;
4+
5+
use DateTime;
6+
use Exception;
7+
use SiroDiaz\ManticoreMigration\Runner\Loader;
8+
9+
class MigrationCreator
10+
{
11+
protected $migrationsPath;
12+
13+
protected $name;
14+
15+
protected $description;
16+
17+
protected $createdAt;
18+
19+
public function __construct(string $migrationsPath, string $name, string $description = '', DateTime $createdAt = null)
20+
{
21+
$this->migrationsPath = $migrationsPath;
22+
$this->name = $name;
23+
$this->description = $description;
24+
$this->createdAt = $createdAt ?? new DateTime();
25+
}
26+
27+
public function setCreatedAt(DateTime $createdAt): MigrationCreator
28+
{
29+
$this->createdAt = $createdAt;
30+
31+
return $this;
32+
}
33+
34+
protected function generateMigrationFilename(): string
35+
{
36+
return $this->createdAt->format('Y_m_d_His') . '_' . $this->name . '.php';
37+
}
38+
39+
protected function getMigrationFullPath(): string
40+
{
41+
return $this->migrationsPath . DIRECTORY_SEPARATOR . $this->generateMigrationFilename();
42+
}
43+
44+
protected function renderMigrationTemplate(): string
45+
{
46+
$migrationClassName = Loader::getMigrationClassName($this->getMigrationFullPath());
47+
48+
return <<<PHP
49+
<?php
50+
51+
use SiroDiaz\ManticoreMigration\Migration;
52+
use SiroDiaz\ManticoreMigration\Runner\ManticoreRunner;
53+
54+
class {$migrationClassName} extends Migration
55+
{
56+
public \$description = '{$this->description}';
57+
58+
public function up(): void
59+
{
60+
// Your migration code goes here
61+
}
62+
63+
public function down(): void
64+
{
65+
// Your undo migration code goes here
66+
}
67+
}
68+
PHP;
69+
}
70+
71+
public function create(): bool
72+
{
73+
if (file_exists($this->getMigrationFullPath())) {
74+
throw new Exception('Migration already exists');
75+
}
76+
77+
return file_put_contents($this->getMigrationFullPath(), $this->renderMigrationTemplate()) !== false;
78+
}
79+
80+
protected function exists(): bool
81+
{
82+
file_exists($this->migrationsPath . DIRECTORY_SEPARATOR . $this->name . '.php');
83+
return true;
84+
}
85+
}

‎src/MigrationDirector.php

+10-2
Original file line numberDiff line numberDiff line change
@@ -106,7 +106,7 @@ protected function hasDuplicatedMigrations(array $pendingMigrationFilenames): bo
106106
/**
107107
* @return array
108108
*/
109-
private function getPendingMigrations(): array
109+
public function getPendingMigrations(): array
110110
{
111111
$migrations = Loader::load($this->migrationsPath);
112112

@@ -133,6 +133,11 @@ function ($migration, $file) use ($pendingMigrationFilenames) {
133133
);
134134
}
135135

136+
public function hasPendingMigrations(): bool
137+
{
138+
return count($this->getPendingMigrations()) > 0;
139+
}
140+
136141
protected function requireClassFile(string $file)
137142
{
138143
if (!file_exists($file)) {
@@ -176,7 +181,10 @@ public function getMigrationTable(): MigrationTable
176181
public function migrate(): void
177182
{
178183
try {
179-
!$this->migrationTable->exists() && $this->migrationTable->create();
184+
if (!$this->migrationTable->exists()) {
185+
$this->migrationTable->create();
186+
}
187+
180188
$this->runPendingMigrations($this->getPendingMigrations());
181189
} catch (Exception $e) {
182190
throw $e;

‎src/Storage/Database/Adapters/Schema/Mysql.php

Whitespace-only changes.

‎src/Storage/Database/Adapters/Schema/Pgsql.php

Whitespace-only changes.

‎src/Storage/Database/Adapters/Schema/Sqlite.php

+93
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,93 @@
1+
<?php
2+
3+
namespace SiroDiaz\ManticoreMigration\Storage\Database\Adapters\Schema;
4+
5+
use SiroDiaz\ManticoreMigration\Storage\DatabaseConnection;
6+
7+
class Sqlite extends AbstractSchema
8+
{
9+
protected $connection;
10+
11+
public function __construct(DatabaseConnection $connection)
12+
{
13+
$this->connection = $connection;
14+
}
15+
16+
public function createTable(string $tableName, array $columns): void
17+
{
18+
$this->connection->execute(
19+
"CREATE TABLE {$this->tablePrefix}{$tableName} (" . implode(', ', $columns) . ')'
20+
);
21+
}
22+
23+
public function dropTable(string $tableName): void
24+
{
25+
$this->connection->execute("DROP TABLE {$this->tablePrefix}{$tableName}");
26+
}
27+
28+
public function renameTable(string $oldName, string $newName): void
29+
{
30+
$this->connection->execute("ALTER TABLE {$this->tablePrefix}{$oldName} RENAME TO {$this->tablePrefix}{$newName}");
31+
}
32+
33+
public function addColumn(string $tableName, string $columnName, string $columnType): void
34+
{
35+
$this->connection->execute("ALTER TABLE {$this->tablePrefix}{$tableName} ADD COLUMN {$columnName} {$columnType}");
36+
}
37+
38+
public function dropColumn(string $tableName, string $columnName): void
39+
{
40+
$this->connection->execute("ALTER TABLE {$this->tablePrefix}{$tableName} DROP COLUMN {$columnName}");
41+
}
42+
43+
public function renameColumn(string $tableName, string $oldName, string $newName): void
44+
{
45+
$this->connection->execute("ALTER TABLE {$this->tablePrefix}{$tableName} RENAME COLUMN {$oldName} TO {$newName}");
46+
}
47+
48+
public function changeColumn(string $tableName, string $columnName, string $columnType): void
49+
{
50+
$this->connection->execute("ALTER TABLE {$this->tablePrefix}{$tableName} ALTER COLUMN {$columnName} {$columnType}");
51+
}
52+
53+
public function addIndex(string $tableName, string $columnName, string $indexName = null): void
54+
{
55+
$this->connection->execute("CREATE INDEX {$indexName} ON {$this->tablePrefix}{$tableName} ({$columnName})");
56+
}
57+
58+
public function dropIndex(string $tableName, string $indexName): void
59+
{
60+
$this->connection->execute("DROP INDEX {$indexName} ON {$this->tablePrefix}{$tableName}");
61+
}
62+
63+
public function addForeignKey(string $tableName, string $columnName, string $refTableName, string $refColumnName): void
64+
{
65+
$this->connection->execute("ALTER TABLE {$this->tablePrefix}{$tableName} ADD FOREIGN KEY ({$columnName}) REFERENCES {$this->tablePrefix}{$refTableName} ({$refColumnName})");
66+
}
67+
68+
public function dropForeignKey(string $tableName, string $columnName): void
69+
{
70+
$this->connection->execute("ALTER TABLE {$this->tablePrefix}{$tableName} DROP FOREIGN KEY ({$columnName})");
71+
}
72+
73+
public function addPrimaryKey(string $tableName, string $columnName): void
74+
{
75+
$this->connection->execute("ALTER TABLE {$this->tablePrefix}{$tableName} ADD PRIMARY KEY ({$columnName})");
76+
}
77+
78+
public function dropPrimaryKey(string $tableName): void
79+
{
80+
$this->connection->execute("ALTER TABLE {$this->tablePrefix}{$tableName} DROP PRIMARY KEY");
81+
}
82+
83+
public function addUniqueKey(string $tableName, string $columnName, string $indexName = null): void
84+
{
85+
$this->connection->execute("CREATE UNIQUE INDEX {$indexName} ON {$this->tablePrefix}{$tableName} ({$columnName})");
86+
}
87+
88+
public function dropUniqueKey(string $tableName, string $indexName): void
89+
{
90+
$this->connection->execute("DROP INDEX {$indexName} ON {$this->tablePrefix}{$tableName}");
91+
}
92+
93+
}

‎src/Storage/Database/MigrationTableFactory.php

Whitespace-only changes.

‎src/Storage/MigrationTable.php

-1
Original file line numberDiff line numberDiff line change
@@ -94,7 +94,6 @@ public function exists()
9494
public function create()
9595
{
9696
$databaseDriver = $this->connection->getConfiguration()->getDriver();
97-
9897
// $migrationTableCreator = new MigrationTableCreator($databaseDriver);
9998

10099
// var_dump($migrationTableCreator->getTableSchema($this->getFullTableName()));

‎stubs/migration.stub

+31
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,31 @@
1+
<?php
2+
3+
use SiroDiaz\ManticoreMigration\Indexer\Indexer;
4+
use SiroDiaz\ManticoreMigration\Migration;
5+
use SiroDiaz\ManticoreMigration\Runner\ManticoreRunner;
6+
7+
class %s extends Migration
8+
{
9+
public $description = '%s';
10+
11+
/**
12+
* Run the migrations.
13+
*
14+
* @return void
15+
*/
16+
public function up(): void {
17+
// create, alter index fields, etc.
18+
$this->runner->execute('CREATE TABLE ...');
19+
// load an index with the data comming from a SQL database
20+
$this->indexer->index('users', 'SELECT id, name, username, biography, birthdate FROM users');
21+
}
22+
23+
/**
24+
* Reverse the migrations.
25+
*
26+
* @return void
27+
*/
28+
public function down(): void {
29+
$this->runner->execute('DROP TABLE ...');
30+
}
31+
}

‎tests/MigrationCreatorTest.php

+15
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,15 @@
1+
<?php
2+
3+
namespace SiroDiaz\ManticoreMigration\Tests;
4+
5+
6+
use PHPUnit\Framework\TestCase;
7+
8+
class MigrationCreatorTest extends TestCase
9+
{
10+
/** @test */
11+
public function it_should_create_a_migration_creator_instance_successfully()
12+
{
13+
14+
}
15+
}

0 commit comments

Comments
 (0)
Please sign in to comment.