using Npgsql;
using System;
using System.Collections.Generic;
using System.Data;
using System.Data.SqlClient;
using System.IO;
using System.Linq;
using System.Net;
using System.Text;
using System.Web;
using System.Web.Script.Serialization;
using System.Web.UI;
using System.Web.UI.WebControls;

public partial class _Default : System.Web.UI.Page
{
    protected void Page_Load(object sender, EventArgs e)
    {

    }

    protected void Button1_Click(object sender, EventArgs e)
    {
        VnesiFilmovi(1);
    }


    public void VnesiFilmovi(int indeks)
    {
        //dinamicki dodaj niza od stringovi
        String film = "Maleficent,Whiplash,Interstellar,The Hateful Eight,Ant-Man,Black Mass,Cinderella,Divergent,Furious 7,Fifty Shades of Grey";
        string[] filmovi = film.Split(',');
        int id = indeks;
        string godina = "";
        string rejting="";
        string zhanr="";
        DateTime dt;
        string fslika_url = "";
        string fopis = "";
        string fnagradi = "";
        string fime = "";
        bool flag = true;

        NpgsqlConnection con = new NpgsqlConnection("Server=localhost;Port=5555;User Id=db_201617z_va_proekt_moviediary_com_owner;Password=moviediary_com;Database=db_201617z_va_proekt_moviediary_com;");
        //string sql = "INSERT INTO akteri(a_id,aime) VALUES (@id,@ime);";
       // string sql = "SELECT * FROM akteri";

        NpgsqlCommand komanda = new NpgsqlCommand();
        komanda.CommandText = "INSERT INTO filmovi VALUES(@f_id,@zhanr,@rejting,@godina,@fslika_url,@fopis,@fnagradi,@fime); ";
        komanda.Connection = con;
        NpgsqlDataAdapter da = new NpgsqlDataAdapter(komanda);
       // DataSet ds = new DataSet();
        //cmd.Parameters.AddWithValue("@id", 3);
        //cmd.Parameters.AddWithValue("@ime", "Iljo");

        WebClient client = new WebClient();
        JavaScriptSerializer j = new JavaScriptSerializer();
        //////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
        foreach (string stavi in filmovi)
        {
            string downloadString = client.DownloadString("http://www.omdbapi.com/?t=" + stavi);
            Dictionary<string, object> dictionary = j.Deserialize<Dictionary<string, object>>(downloadString);
            flag = true;

            if (dictionary.ContainsKey("Error"))//proverka dali postoi filmot
            {
                TextBox2.Text += dictionary["Error"].ToString() + " " + stavi + System.Environment.NewLine;
                flag = false;
            }

            if (dictionary.ContainsKey("Title"))
            {
                zhanr = dictionary["Genre"].ToString();
                godina = dictionary["Year"].ToString();

                rejting = dictionary["imdbRating"].ToString();
                fslika_url = dictionary["Poster"].ToString();
                fopis = dictionary["Plot"].ToString();
                fime = dictionary["Title"].ToString();
                fnagradi =dictionary["Awards"].ToString();
                TextBox2.Text += stavi + " uspesno pronajden" + System.Environment.NewLine;
            }

            if (flag)
            {

                komanda.Parameters.AddWithValue("@f_id", id);
                komanda.Parameters.AddWithValue("@zhanr", zhanr);
                komanda.Parameters.AddWithValue("@rejting", rejting);
                komanda.Parameters.AddWithValue("@godina", godina);
                komanda.Parameters.AddWithValue("@fslika_url",fslika_url);
                komanda.Parameters.AddWithValue("@fopis",fopis);
                komanda.Parameters.AddWithValue("@fnagradi",fnagradi);
                komanda.Parameters.AddWithValue("@fime",fime);


         try
        {
            con.Open();
           // da.Fill(ds, "Akteri");
           // ListBox1.DataTextField = "aime";
          //  ListBox1.DataSource = ds.Tables["Akteri"];
          //  ListBox1.DataBind();
            id++;
            komanda.ExecuteNonQuery();
        }
        catch (Exception err)
        {
            TextBox2.Text = err.Message + System.Environment.NewLine;
        }
        finally
        {
           con.Close();
           komanda.Parameters.Clear();
        }



            }


        }



    }


}