SQL UPDATE没有更新数据库,我的SQL语句有问题吗?
本文关键字:SQL 语句 有问题 我的 数据库 UPDATE 更新 | 更新日期: 2023-09-27 17:52:42
这是我第一次尝试编写一个真正的c#程序。它接受指定的目录,提取文件名(不带扩展名)并将其写入SQL数据库。然后将该数据读入数组并传递到下面的'foreach'循环。然后循环使用数据搜索IMDB,并将第一个结果的URL存储到DB中。然后,它将这些数据读取回一个变量,并使用该变量从页面中"抓取"数据,如导演、演员、情节等。
我有程序工作的权利,以更新数据库在结束与导演,演员,情节等数据。我已经深入到程序中,所有变量都包含正确的值,就在表单在DataGrid中加载表时,它显示了我之前在循环中添加的所有数据,但不显示导演等。
由于这些原因,我认为我在程序末尾的SQL语句可能是错误的。我知道代码可能效率很低,而且很混乱,但我是新手,所以放轻松!
foreach (string title in titles)
{
//Use each title in titles array to search IMDB and return the page URL
string searchURL = "http://www.imdb.com/find?s=all&q=" + title;
string url = searchURL;
string sourceCode = WorkerClass.getSourceCode(url);
int startIndex = sourceCode.IndexOf("Media from ");
sourceCode = sourceCode.Substring(startIndex, sourceCode.Length - startIndex);
startIndex = sourceCode.IndexOf("<a href=") + 9;
int endIndex = sourceCode.IndexOf('"' + " onclick", startIndex);
string link = "http://www.imdb.com" + (sourceCode.Substring(startIndex, endIndex - startIndex));
//Update DB to add page url based on title
SqlConnection con = new SqlConnection(DataAccess.GetConnectionString("dbCon"));
//Create SQL Command
var command = new SqlCommand("UPDATE movieTable SET imdbPageURL=@pageURL WHERE title=@title", con);
command.Parameters.AddWithValue("@pageURL", link);
command.Parameters.AddWithValue("@title", title);
con.Open();
//Add to DB
command.ExecuteNonQuery();
con.Close();
//Select IMDB Page URL from movieTable where the title = current title
var com = new SqlCommand("SELECT imdbPageURL FROM movieTable WHERE title=@title", con);
con.Open();
com.Parameters.AddWithValue("@title", title);
string pageURL = (string)com.ExecuteScalar();
con.Close();
//Get Director
sourceCode = WorkerClass.getSourceCode(pageURL);
startIndex = sourceCode.IndexOf("description");
sourceCode = sourceCode.Substring(startIndex, sourceCode.Length - startIndex);
startIndex = sourceCode.IndexOf("content=") +21;
endIndex = sourceCode.IndexOf('.' , startIndex);
string director = sourceCode.Substring(startIndex, endIndex - startIndex);
//Get Cast
sourceCode = WorkerClass.getSourceCode(pageURL);
startIndex = sourceCode.IndexOf("content=");
sourceCode = sourceCode.Substring(startIndex, sourceCode.Length - startIndex);
startIndex = sourceCode.IndexOf('.') +2;
endIndex = sourceCode.IndexOf("/>", startIndex) -3;
string cast = sourceCode.Substring(startIndex, endIndex - startIndex);
//Get Plot
sourceCode = WorkerClass.getSourceCode(pageURL);
startIndex = sourceCode.IndexOf("Users:");
sourceCode = sourceCode.Substring(startIndex, sourceCode.Length - startIndex);
startIndex = sourceCode.IndexOf("</div>");
endIndex = sourceCode.IndexOf("<div", startIndex);
sourceCode = sourceCode.Substring(startIndex, endIndex - startIndex);
startIndex = sourceCode.IndexOf("<p>") +7;
endIndex = sourceCode.IndexOf("</p>");
string plot = sourceCode.Substring(startIndex, endIndex - startIndex);
//Get Rating
sourceCode = WorkerClass.getSourceCode(pageURL);
startIndex = sourceCode.IndexOf("infobar");
sourceCode = sourceCode.Substring(startIndex, sourceCode.Length - startIndex);
startIndex = sourceCode.IndexOf("alt=") +5;
endIndex = sourceCode.IndexOf("src=", startIndex) -2;
string rating = sourceCode.Substring(startIndex, endIndex - startIndex);
//Get Release Date
sourceCode = WorkerClass.getSourceCode(pageURL);
startIndex = sourceCode.IndexOf("infobar");
sourceCode = sourceCode.Substring(startIndex, sourceCode.Length - startIndex);
startIndex = sourceCode.IndexOf("nobr");
endIndex = sourceCode.IndexOf("</div>", startIndex);
sourceCode = sourceCode.Substring(startIndex, endIndex - startIndex);
startIndex = sourceCode.IndexOf("dates") +11;
endIndex = sourceCode.IndexOf("</a") -4;
string releaseDate = sourceCode.Substring(startIndex, endIndex - startIndex);
//Get link to Cover Image
sourceCode = WorkerClass.getSourceCode(pageURL);
startIndex = sourceCode.IndexOf("img_primary");
sourceCode = sourceCode.Substring(startIndex, sourceCode.Length - startIndex);
startIndex = sourceCode.IndexOf("<img src=") + 10;
endIndex = sourceCode.IndexOf(".jpg", startIndex) +4;
string coverURL = sourceCode.Substring(startIndex, endIndex - startIndex);
//Update movieTable with scraped data for the current title
var comd = new SqlCommand("UPDATE movieTable SET director=@director, cast=@cast, plot=@plot, rating=@rating, releaseDate=@releaseDate, coverURL=@coverURL WHERE title=@title", con);
comd.Parameters.AddWithValue("@title", title);
comd.Parameters.AddWithValue("@director", director);
comd.Parameters.AddWithValue("@cast", cast);
comd.Parameters.AddWithValue("@plot", plot);
comd.Parameters.AddWithValue("@rating", rating);
comd.Parameters.AddWithValue("@releaseDate", releaseDate);
comd.Parameters.AddWithValue("@coverURL", coverURL);
con.Open();
//Add to DB
command.ExecuteNonQuery();
con.Close();
}
this.movieTableTableAdapter.Fill(this.movieLibraryDBDataSet.movieTable);
最后一次执行使用的是command
对象,而不是稍后为更新定义的comd
对象。
记录是否已经存在?我认为你需要做一个插入手术。UPDATE只更新现有记录