HomeMonitor/Weather/Service/Data/Database.cs

using ChrisKaczor.HomeMonitor.Weather.Models;
using Dapper;
using Microsoft.Extensions.Configuration;
using System.Data.SqlClient;

namespace ChrisKaczor.HomeMonitor.Weather.Service.Data
{
    public class Database
    {
        private readonly IConfiguration _configuration;

        public Database(IConfiguration configuration)
        {
            _configuration = configuration;
        }

        public void EnsureDatabase()
        {
            var connectionStringBuilder = new SqlConnectionStringBuilder
            {
                DataSource = _configuration["Weather:Database:Host"],
                UserID = _configuration["Weather:Database:User"],
                Password = _configuration["Weather:Database:Password"],
                InitialCatalog = "master"
            };

            using (var connection = new SqlConnection(connectionStringBuilder.ConnectionString))
            {
                var command = new SqlCommand { Connection = connection };

                connection.Open();

                // Check to see if the database exists
                command.CommandText = $"SELECT CAST(1 as bit) from sys.databases WHERE name='{_configuration["Weather:Database:Name"]}'";
                var databaseExists = (bool?)command.ExecuteScalar();

                // Create database if needed
                if (!databaseExists.GetValueOrDefault(false))
                {
                    command.CommandText = $"CREATE DATABASE {_configuration["Weather:Database:Name"]}";
                    command.ExecuteNonQuery();
                }

                // Switch to the database now that we're sure it exists
                connection.ChangeDatabase(_configuration["Weather:Database:Name"]);

                var schema = ResourceReader.GetString("ChrisKaczor.HomeMonitor.Weather.Service.Data.Resources.Schema.sql");

                // Make sure the database is up to date
                command.CommandText = schema;
                command.ExecuteNonQuery();
            }
        }

        private SqlConnection CreateConnection()
        {
            var connectionStringBuilder = new SqlConnectionStringBuilder
            {
                DataSource = _configuration["Weather:Database:Host"],
                UserID = _configuration["Weather:Database:User"],
                Password = _configuration["Weather:Database:Password"],
                InitialCatalog = _configuration["Weather:Database:Name"]
            };

            var connection = new SqlConnection(connectionStringBuilder.ConnectionString);
            connection.Open();

            return connection;
        }

        public void StoreWeatherData(WeatherMessage weatherMessage)
        {
            using (var connection = CreateConnection())
            {
                var query = ResourceReader.GetString("ChrisKaczor.HomeMonitor.Weather.Service.Data.Resources.CreateReading.sql");

                connection.Query(query, weatherMessage);
            }
        }
    }
}