wundergraph_example supports MySql

Author: Alexei Pastuchov

wundergraph_example/Cargo.toml

@@ -29,5 +29,6 @@ default-features = false
 
 [features]
 default = ["postgres", "wundergraph/debug"]
-sqlite = ["wundergraph/sqlite", "diesel/sqlite"]
+mysql = ["wundergraph/mysql", "diesel/mysql"]
 postgres = ["wundergraph/postgres", "diesel/postgres"]
+sqlite = ["wundergraph/sqlite", "diesel/sqlite"]

wundergraph_example/migrations/mysql/2018-01-24-131925_setup/down.sql

@@ -0,0 +1,7 @@
+-- This file should undo anything in `up.sql`
+
+DROP TABLE friends;
+DROP TABLE appears_in;
+DROP TABLE heros;
+DROP TABLE home_worlds;
+DROP TABLE species;

wundergraph_example/migrations/mysql/2018-01-24-131925_setup/up.sql

@@ -0,0 +1,60 @@
+CREATE TABLE `species`(
+    `id` INTEGER NOT NULL AUTO_INCREMENT,
+    `name` TEXT NOT NULL,
+    PRIMARY KEY (`id`)
+);
+
+CREATE TABLE `home_worlds`(
+    `id` INTEGER NOT NULL AUTO_INCREMENT,
+    `name` TEXT NOT NULL,
+    PRIMARY KEY (`id`)
+);
+
+CREATE TABLE `heros`(
+    `id` INTEGER NOT NULL AUTO_INCREMENT,
+    `name` TEXT NOT NULL,
+    `hair_color` TEXT,
+    `species` INTEGER NOT NULL,
+    `home_world` INTEGER DEFAULT NULL,
+    PRIMARY KEY (`id`),
+    FOREIGN KEY (`species`) REFERENCES `species` (`id`) ON DELETE CASCADE ON UPDATE RESTRICT,
+    FOREIGN KEY (`home_world`) REFERENCES `home_worlds` (`id`) ON DELETE CASCADE ON UPDATE RESTRICT
+);
+
+CREATE TABLE `appears_in`(
+    `hero_id` INTEGER NOT NULL,
+    `episode` SMALLINT(1) NOT NULL CHECK(episode IN (1,2,3)),
+    PRIMARY KEY(`hero_id`, `episode`),
+    FOREIGN KEY (`hero_id`) REFERENCES `heros` (`id`) ON DELETE CASCADE ON UPDATE RESTRICT
+);
+
+CREATE TABLE `friends`(
+    `hero_id` INTEGER NOT NULL,
+    `friend_id` INTEGER NOT NULL,
+    PRIMARY KEY(`hero_id`, `friend_id`),
+    FOREIGN KEY (`hero_id`) REFERENCES `heros`(`id`) ON DELETE CASCADE ON UPDATE RESTRICT,
+    FOREIGN KEY (`friend_id`) REFERENCES `heros` (`id`) ON DELETE CASCADE ON UPDATE RESTRICT
+);
+
+INSERT INTO species(id, name) VALUES (1, 'Human'), (2, 'Robot');
+
+INSERT INTO home_worlds(id, name) VALUES(1, 'Tatooine'), (2, 'Alderaan');
+
+INSERT INTO heros(id, name, species, home_world, hair_color)
+    VALUES (1, 'Luke Skywalker', 1, 1, 'blond'),
+           (2, 'Darth Vader', 1, 1, DEFAULT),
+           (3, 'Han Solo', 1, Null, DEFAULT),
+           (4, 'Leia Organa', 1, 2, DEFAULT),
+           (5, 'Wilhuff Tarkin', 1, Null, DEFAULT);
+
+INSERT INTO appears_in(hero_id, episode)
+    VALUES (1, 1), (1, 2), (1, 3),
+           (2, 1), (2, 2), (2, 3),
+           (3, 1), (3, 2), (3, 3),
+           (4, 1), (4, 2), (4, 3),
+           (5, 3);
+
+
+INSERT INTO friends(hero_id, friend_id)
+    VALUES (1, 3), (1, 4), (2, 5), (3, 1),
+           (3, 4), (4, 1), (4, 3), (5, 2);

wundergraph_example/src/bin/wundergraph_example.rs

@@ -83,7 +83,10 @@ fn run_migrations(conn: &DBConnection) {
         migration_path.push("pg");
     } else if cfg!(feature = "sqlite") {
         migration_path.push("sqlite");
+    } else if cfg!(feature = "mysql") {
+        migration_path.push("mysql");
     }
+
     let pending_migrations =
         ::diesel_migrations::mark_migrations_in_directory(conn, &migration_path)
             .unwrap()

wundergraph_example/src/lib.rs

@@ -261,6 +261,9 @@ pub type DBConnection = ::diesel::PgConnection;
 #[cfg(feature = "sqlite")]
 pub type DBConnection = ::diesel::SqliteConnection;
 
+#[cfg(feature = "mysql")]
+pub type DBConnection = ::diesel::MysqlConnection;
+
 pub type DbBackend = <DBConnection as Connection>::Backend;
 
 pub type Schema<Ctx> =

wundergraph_example/src/mutations.rs

@@ -11,6 +11,9 @@ use super::HomeWorld;
 use super::Species;
 use juniper::*;
 
+#[cfg(feature = "mysql")]
+pub mod mysql;
+
 #[derive(Insertable, GraphQLInputObject, Clone, Debug)]
 #[table_name = "heros"]
 pub struct NewHero {