68 lines
3.0 KiB
C#
68 lines
3.0 KiB
C#
|
using System.Data;
|
|||
|
|
using Dapper;
|
|||
|
|
using MySql.Data;
|
|||
|
|
using MySql.Data.MySqlClient;
|
|||
|
|
using Tesses.YouTubeDownloader;
|
|||
|
|
|
|||
|
|
/*edit this according to your db and TYTD*/
|
|||
|
|
string username = "root";
|
|||
|
|
string database="tytd";
|
|||
|
|
string password="";
|
|||
|
|
string server="127.0.0.1";
|
|||
|
|
int port=6244;
|
|||
|
|
string dir="/mnt/8TBShare/Videos/TYTD/Wii";
|
|||
|
|
bool created=false;
|
|||
|
|
|
|||
|
|
|
|||
|
|
MySql.Data.MySqlClient.MySqlConnection connection=new MySql.Data.MySqlClient.MySqlConnection($"Server={server}; port={port}; database={database}; UID={username}; password={password}");
|
|||
|
|
await connection.OpenAsync();
|
|||
|
|
if(!created){
|
|||
|
|
MySqlCommand command = new MySqlCommand("CREATE TABLE VideoId (VideoId varchar(11), Title varchar(100), Description text, Views bigint, Likes bigint, Dislikes bigint, UploadDate bigint, Keywords text, AddDate bigint, AuthorTitle varchar(100), AuthorId varchar(24), TYTDTag text);", connection);
|
|||
|
|
var reader=await command.ExecuteReaderAsync();
|
|||
|
|
while(reader.Read())
|
|||
|
|
{
|
|||
|
|
string someStringFromColumnZero = reader.GetString(0);
|
|||
|
|
string someStringFromColumnOne = reader.GetString(1);
|
|||
|
|
Console.WriteLine(someStringFromColumnZero + "," + someStringFromColumnOne);
|
|||
|
|
}
|
|||
|
|
}else {
|
|||
|
|
string insertInto = "INSERT INTO SavedVideo (Id,Title,Description,Views,Likes,Dislikes,UploadDate,Keywords,AddDate,AuthorTitle,AuthorId,TYTDTag) values (@Id,@Title,@Description,@Views,@Likes,@Dislikes,@UploadDate,@Keywords,@AddDate,@AuthorTitle,@AuthorId,@TYTDTag);";
|
|||
|
|
async Task AddVideoToTable(SavedVideo video)
|
|||
|
|
{
|
|||
|
|
//string mysqlCommand = $"INSERT INTO SavedVideo ('{MySqlHelper.EscapeString(video.Id)}','{MySqlHelper.EscapeString(video.Title)}','{MySqlHelper.EscapeString(video.Description)}','{video.Views}','{video.Likes}','{video.Dislikes}','{}','{MySqlHelper.EscapeString()}','{new DateTimeOffset(video.AddDate).ToUnixTimeSeconds()}','{MySqlHelper.EscapeString(video.AuthorTitle)}','{MySqlHelper.EscapeString(video.AuthorChannelId)}','{MySqlHelper.EscapeString(video.TYTDTag)}');";
|
|||
|
|
await connection.ExecuteAsync(insertInto,new{
|
|||
|
|
Id=video.Id,
|
|||
|
|
Title=video.Title,
|
|||
|
|
Description=video.Description,
|
|||
|
|
Views = video.Views,
|
|||
|
|
Likes = video.Likes,
|
|||
|
|
Dislikes=video.Dislikes,
|
|||
|
|
UploadDate =new DateTimeOffset(video.UploadDate).ToUnixTimeSeconds(),
|
|||
|
|
Keywords=string.Join(",",video.Keywords),
|
|||
|
|
AddDate=new DateTimeOffset(video.AddDate).ToUnixTimeSeconds(),
|
|||
|
|
AuthorTitle = video.AuthorTitle,
|
|||
|
|
AuthorId = video.AuthorChannelId,
|
|||
|
|
TYTDTag = video.TYTDTag
|
|||
|
|
});
|
|||
|
|
}
|
|||
|
|
TYTDPathDirectory directory=new TYTDPathDirectory(dir);
|
|||
|
|
await foreach (var item in directory.GetVideoIdsAsync())
|
|||
|
|
{ string name = $"https://www.youtube.com/watch?v={item}";
|
|||
|
|
try{
|
|||
|
|
|
|||
|
|
var savedVideo = await directory.GetVideoInfoAsync(item);
|
|||
|
|
name = $"{savedVideo.Title} - {savedVideo.Id}";
|
|||
|
|
await AddVideoToTable(savedVideo);
|
|||
|
|
Console.WriteLine($"{name} Added");
|
|||
|
|
|
|||
|
|
}catch(Exception ex)
|
|||
|
|
{
|
|||
|
|
Console.WriteLine($"{name} Already Added");
|
|||
|
|
//Console.WriteLine(ex);
|
|||
|
|
_=ex;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
await connection.CloseAsync();
|