Add getting started guide step 3 to the main repo

Author: sgrif

examples/getting_started_step_3/Cargo.toml

@@ -0,0 +1,10 @@
+[package]
+name = "diesel_demo"
+version = "0.1.0"
+authors = ["Sean Griffin <sean@seantheprogrammer.com>"]
+
+[dependencies]
+diesel = "0.7.1"
+diesel_codegen = { version = "0.7.2", features = ["postgres"] }
+dotenv = "0.8.0"
+dotenv_macros = "0.9.0"

examples/getting_started_step_3/migrations/20160815133237_create_posts/down.sql

@@ -0,0 +1 @@
+DROP TABLE posts

examples/getting_started_step_3/migrations/20160815133237_create_posts/up.sql

@@ -0,0 +1,6 @@
+CREATE TABLE posts (
+  id SERIAL PRIMARY KEY,
+  title VARCHAR NOT NULL,
+  body TEXT NOT NULL,
+  published BOOLEAN NOT NULL DEFAULT 'f'
+)

examples/getting_started_step_3/src/bin/delete_post.rs

@@ -0,0 +1,20 @@
+extern crate diesel_demo;
+extern crate diesel;
+
+use diesel::prelude::*;
+use diesel_demo::*;
+use std::env::args;
+
+fn main() {
+    use diesel_demo::schema::posts::dsl::*;
+
+    let target = args().nth(1).expect("Expected a target to match against");
+    let pattern = format!("%{}%", target);
+
+    let connection = establish_connection();
+    let num_deleted = diesel::delete(posts.filter(title.like(pattern)))
+        .execute(&connection)
+        .expect("Error deleting posts");
+
+    println!("Deleted {} posts", num_deleted);
+}

examples/getting_started_step_3/src/bin/publish_post.rs

@@ -0,0 +1,21 @@
+extern crate diesel_demo;
+extern crate diesel;
+
+use diesel::prelude::*;
+use diesel_demo::*;
+use diesel_demo::models::Post;
+use std::env::args;
+
+fn main() {
+    use diesel_demo::schema::posts::dsl::{posts, published};
+
+    let id = args().nth(1).expect("publish_post requires a post id")
+        .parse::<i32>().expect("Invalid ID");
+    let connection = establish_connection();
+
+    let post = diesel::update(posts.find(id))
+        .set(published.eq(true))
+        .get_result::<Post>(&connection)
+        .expect(&format!("Unable to find post {}", id));
+    println!("Published post {}", post.title);
+}

examples/getting_started_step_3/src/bin/show_posts.rs

@@ -0,0 +1,23 @@
+extern crate diesel_demo;
+extern crate diesel;
+
+use diesel_demo::*;
+use diesel_demo::models::*;
+use diesel::prelude::*;
+
+fn main() {
+    use diesel_demo::schema::posts::dsl::*;
+
+    let connection = establish_connection();
+    let results = posts.filter(published.eq(true))
+        .limit(5)
+        .load::<Post>(&connection)
+        .expect("Error loading posts");
+
+    println!("Displaying {} posts", results.len());
+    for post in results {
+        println!("{}", post.title);
+        println!("-----------\n");
+        println!("{}", post.body);
+    }
+}

examples/getting_started_step_3/src/bin/write_post.rs

@@ -0,0 +1,28 @@
+extern crate diesel_demo;
+extern crate diesel;
+
+use self::diesel_demo::*;
+use std::io::{stdin, Read};
+
+fn main() {
+    let connection = establish_connection();
+
+    let mut title = String::new();
+    let mut body = String::new();
+
+    println!("What would you like your title to be?");
+    stdin().read_line(&mut title).unwrap();
+    let title = title.trim_right(); // Remove the trailing newline
+
+    println!("\nOk! Let's write {} (Press {} when finished)\n", title, EOF);
+    stdin().read_to_string(&mut body).unwrap();
+
+    let post = create_post(&connection, title, &body);
+    println!("\nSaved draft {} with id {}", title, post.id);
+}
+
+#[cfg(not(windows))]
+const EOF: &'static str = "CTRL+D";
+
+#[cfg(windows)]
+const EOF: &'static str = "CTRL+Z";

examples/getting_started_step_3/src/lib.rs

@@ -0,0 +1,37 @@
+#![feature(custom_derive, custom_attribute, plugin)]
+#![plugin(diesel_codegen, dotenv_macros)]
+
+#[macro_use] extern crate diesel;
+extern crate dotenv;
+
+pub mod schema;
+pub mod models;
+
+use diesel::prelude::*;
+use diesel::pg::PgConnection;
+use dotenv::dotenv;
+use std::env;
+
+use self::models::{Post, NewPost};
+
+pub fn establish_connection() -> PgConnection {
+    dotenv().ok();
+
+    let database_url = env::var("DATABASE_URL")
+        .expect("DATABASE_URL must be set");
+    PgConnection::establish(&database_url)
+        .expect(&format!("Error connecting to {}", database_url))
+}
+
+pub fn create_post(conn: &PgConnection, title: &str, body: &str) -> Post {
+    use schema::posts;
+
+    let new_post = NewPost {
+        title: title,
+        body: body,
+    };
+
+    diesel::insert(&new_post).into(posts::table)
+        .get_result(conn)
+        .expect("Error saving new post")
+}

examples/getting_started_step_3/src/models.rs

@@ -0,0 +1,15 @@
+use schema::posts;
+
+#[derive(Queryable)]
+pub struct Post {
+    pub id: i32,
+    pub title: String,
+    pub body: String,
+    pub published: bool,
+}
+
+#[insertable_into(posts)]
+pub struct NewPost<'a> {
+    pub title: &'a str,
+    pub body: &'a str,
+}

examples/getting_started_step_3/src/schema.rs

@@ -0,0 +1 @@
+infer_schema!(dotenv!("DATABASE_URL"));