using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using Npgsql;

namespace GooglePing.Database
{
    public class PostgreSaver : IDbSaver
    {
        public PostgreSaver()
        {
            npgsqlConnection = new NpgsqlConnection();
            NpgsqlConnectionStringBuilder builder = new NpgsqlConnectionStringBuilder();
            builder.Host = "10.10.1.11";
            builder.Port = 5432;
            builder.UserName = "postgres";
            builder.Password = "123";
            npgsqlConnection.ConnectionString = builder.ConnectionString;
            npgsqlConnection.Open();
        }

        public void Save(WebLog webLog)
        {
            lock (connectLock)
            {
                using (NpgsqlCommand command = new NpgsqlCommand())
                {
                    command.CommandText = "insert into ping(ping_id, name, url, ip) values(nextval('seq_ping'), @name, @url, @ip)";
                    command.Parameters.Add(new NpgsqlParameter("name", webLog.Name));
                    command.Parameters.Add(new NpgsqlParameter("url", webLog.Url));
                    command.Parameters.Add(new NpgsqlParameter("ip", webLog.Ip));
                    command.Connection = npgsqlConnection;
                    command.ExecuteNonQuery();
                }
            }
        }

        private NpgsqlConnection npgsqlConnection;
        private object connectLock = new object();
    }
}