Add `get_database_connection()`

Function to establish a database connection using a connection pool.

Update `Purchaser::insert()` to take a `PooledConn` instead of a simple
`Conn`.

1 files changed, 13 insertions, 0 deletions

diff --git a/license-generator/src/database.rs b/license-generator/src/database.rs
new file mode 100644
index 0000000..28673c4
--- /dev/null
+++ b/license-generator/src/database.rs
@@ -0,0 +1,13 @@
+use std::env;
+
+use mysql;
+
+use errors::*;
+
+fn get_database_connection() -> Result<mysql::PooledConn> {
+    let connection_url = env::var("DATABASE_URL")?;
+    let pool = mysql::Pool::new_manual(10, 50, connection_url)?;
+    let cx = pool.get_conn()?;
+
+    Ok(cx)
+}