File size: 3,420 Bytes
e26fba6 |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 |
using System;
using System.Collections.Generic;
using System.Text;
using System.Data.SQLite;
using System.IO;
using System.Linq;
namespace MovieFinder.Scraper
{
public class DataService
{
private static SQLiteConnection connection;
private static object sync = new object();
public DataService(string name)
{
connection = new SQLiteConnection(String.Format("Data Source={0};Version=3;", name));
connection.Open();
}
//private DataService() { }
//public static DataService Create()
//{
// return new DataService();
//}
public void ShutDown()
{
connection.Dispose();
}
public void AddMovie(MovieFinder.Data.Movie movie)
{
using (var cmd = new SQLiteCommand(connection))
{
cmd.CommandText = String.Format("INSERT INTO MOVIE(ID,Name,ImageUrl,ReleaseDate,LanguageCode,Description, CreatedDate,ModifiedDate, Version, UniqueID, HasSubtitle) " +
"VALUES({0},'{1}','{2}','{3}','{4}','{5}','{6}','{7}',{8},'{9}',{10})",
movie.ID, Sanitize(movie.Name), movie.ImageUrl, movie.ReleaseDate.ToString("yyyy-MM-dd"),
movie.LanguageCode,Sanitize( movie.Description),
movie.CreateDate.ToString("yyyy-MM-dd"),
movie.ModifiedDate != null ?
movie.ModifiedDate.Value.ToString("yyyy-MM-dd") : null, movie.Version,
movie.UniqueID, movie.MovieLinks.Any(x => x.HasSubtitle) ? 1 : 0);
cmd.ExecuteNonQuery();
foreach (var link in movie.MovieLinks)
{
if (link.FailedAttempts > 3)
continue;
cmd.CommandText = String.Format("INSERT INTO MOVIELINK(ID,MovieID,LinkTitle,PageUrl,PageSiteID,DownloadUrl,DownloadSiteID,Version, HasSubtitle) " +
"VALUES({0},{1},'{2}','{3}','{4}','{5}','{6}',{7},{8})",
link.ID, link.MovieID, Sanitize(link.LinkTitle), link.PageUrl, link.PageSiteID, link.DowloadUrl, link.DownloadSiteID,
link.Version, link.HasSubtitle ? 1 : 0);
cmd.ExecuteNonQuery();
}
}
}
public void UpdateMovieSettings(int version, DateTime createdDate)
{
using (var cmd = new SQLiteCommand(connection))
{
cmd.CommandText = String.Format("UPDATE SETTINGS SET Version = {0}, CreatedDate= '{1}' ", version, createdDate.ToString("yyyy-MM-dd hh:mm:ss"));
cmd.ExecuteNonQuery();
}
}
public int MovieDBVersion
{
get
{
using (var cmd = new SQLiteCommand(connection))
{
cmd.CommandText = "SELECT * FROM Settings LIMIT 1";
using (var reader = cmd.ExecuteReader())
{
reader.Read();
return (int)reader["Version"];
}
}
}
}
private string Sanitize(string text)
{
return text.Replace("'", "''");
}
}
}
|