From 7164533d7cf78555c66ed7402899997c4f2e0979 Mon Sep 17 00:00:00 2001 From: inga-lovinde <52715130+inga-lovinde@users.noreply.github.com> Date: Sun, 4 Jul 2010 16:42:17 +0000 Subject: [PATCH] Localized ShallerDBProcessor operations conflicting with IISMainHandler running --- ImportConsole/ShallerDBProcessor.cs | 166 ++++++++++++++++------------ 1 file changed, 98 insertions(+), 68 deletions(-) diff --git a/ImportConsole/ShallerDBProcessor.cs b/ImportConsole/ShallerDBProcessor.cs index 5f36856..19cef5d 100644 --- a/ImportConsole/ShallerDBProcessor.cs +++ b/ImportConsole/ShallerDBProcessor.cs @@ -144,6 +144,7 @@ namespace FLocal.ImportConsole { private readonly static DateTime UNIX = new DateTime(1970, 1, 1, 0, 0, 0); public static void processDB(string filename) { + List> inserts = new List>(); HashSet discussionsIds = new HashSet(); using(StreamReader reader = new StreamReader(filename)) { int i=0; @@ -161,81 +162,83 @@ namespace FLocal.ImportConsole { if(Config.instance.mainConnection.GetCountByConditions(Post.TableSpec.instance, new ComparisonCondition(Post.TableSpec.instance.getIdSpec(), ComparisonType.EQUAL, postId.ToString())) > 0) { Console.Write("-"); } else { - int localMain = int.Parse(data["Local_Main"]); - int main = int.Parse(data["Main"]); - int UnixTime; - try { - UnixTime = int.Parse(data["UnixTime"]); - } catch(OverflowException) { - UnixTime = 1000*1000*1000; - } - if(UnixTime <= 0) { - UnixTime = 1000*1000*1000; - } - DateTime date = UNIX.AddSeconds(UnixTime).ToLocalTime(); - User user; - string username = data["Username"]; - try { - user = User.LoadByName(username); - } catch(NotFoundInDBException) { - Console.Error.WriteLine("Cannot find user '" + username + "'; creating one..."); - ChangeSetUtil.ApplyChanges( - new InsertChange( - User.TableSpec.instance, - new Dictionary { - { User.TableSpec.FIELD_NAME, new ScalarFieldValue(username) }, - { User.TableSpec.FIELD_REGDATE, new ScalarFieldValue(date.ToUTCString()) }, - { User.TableSpec.FIELD_SHOWPOSTSTOUSERS, new ScalarFieldValue(User.ENUM_SHOWPOSTSTOUSERS_ALL) }, - { User.TableSpec.FIELD_BIOGRAPHY, new ScalarFieldValue("") }, - { User.TableSpec.FIELD_LOCATION, new ScalarFieldValue("") }, - { User.TableSpec.FIELD_SIGNATURE, new ScalarFieldValue("") }, - { User.TableSpec.FIELD_TITLE, new ScalarFieldValue("") }, - { User.TableSpec.FIELD_TOTALPOSTS, new ScalarFieldValue("0") }, - { User.TableSpec.FIELD_USERGROUPID, new ScalarFieldValue("1") }, - } - ) - ); - user = User.LoadByName(data["Username"]); - } - string title = data["Subject"]; - string body = data["Body"]; - PostLayer layer = PostLayer.LoadById(1); - if(data.ContainsKey("Layer")) { - layer = PostLayer.LoadById(int.Parse(data["Layer"])); - } - if(postId == main || postId == localMain) { - //first post in the thread - string legacyBoardName; - if(localMain != 0) { - discussionsIds.Add(main); - legacyBoardName = discussions[main]; - } else { - legacyBoardName = data["Board"]; + inserts.Add(new KeyValuePair(postId, () => { + int localMain = int.Parse(data["Local_Main"]); + int main = int.Parse(data["Main"]); + int UnixTime; + try { + UnixTime = int.Parse(data["UnixTime"]); + } catch(OverflowException) { + UnixTime = 1000*1000*1000; } - Board board; + if(UnixTime <= 0) { + UnixTime = 1000*1000*1000; + } + DateTime date = UNIX.AddSeconds(UnixTime).ToLocalTime(); + User user; + string username = data["Username"]; try { - board = Board.LoadByLegacyName(legacyBoardName); + user = User.LoadByName(username); } catch(NotFoundInDBException) { - throw new ApplicationException("Cannot find board '" + legacyBoardName + "'"); + Console.Error.WriteLine("Cannot find user '" + username + "'; creating one..."); + ChangeSetUtil.ApplyChanges( + new InsertChange( + User.TableSpec.instance, + new Dictionary { + { User.TableSpec.FIELD_NAME, new ScalarFieldValue(username) }, + { User.TableSpec.FIELD_REGDATE, new ScalarFieldValue(date.ToUTCString()) }, + { User.TableSpec.FIELD_SHOWPOSTSTOUSERS, new ScalarFieldValue(User.ENUM_SHOWPOSTSTOUSERS_ALL) }, + { User.TableSpec.FIELD_BIOGRAPHY, new ScalarFieldValue("") }, + { User.TableSpec.FIELD_LOCATION, new ScalarFieldValue("") }, + { User.TableSpec.FIELD_SIGNATURE, new ScalarFieldValue("") }, + { User.TableSpec.FIELD_TITLE, new ScalarFieldValue("") }, + { User.TableSpec.FIELD_TOTALPOSTS, new ScalarFieldValue("0") }, + { User.TableSpec.FIELD_USERGROUPID, new ScalarFieldValue("1") }, + } + ) + ); + user = User.LoadByName(data["Username"]); + } + string title = data["Subject"]; + string body = data["Body"]; + PostLayer layer = PostLayer.LoadById(1); + if(data.ContainsKey("Layer")) { + layer = PostLayer.LoadById(int.Parse(data["Layer"])); } - board.CreateThread(user, title, body, layer, date, postId); - } else { - int parentId = int.Parse(data["Parent"]); - if(parentId == 0) { - parentId = localMain; + if(postId == main || postId == localMain) { + //first post in the thread + string legacyBoardName; + if(localMain != 0) { + discussionsIds.Add(main); + legacyBoardName = discussions[main]; + } else { + legacyBoardName = data["Board"]; + } + Board board; + try { + board = Board.LoadByLegacyName(legacyBoardName); + } catch(NotFoundInDBException) { + throw new ApplicationException("Cannot find board '" + legacyBoardName + "'"); + } + board.CreateThread(user, title, body, layer, date, postId); + } else { + int parentId = int.Parse(data["Parent"]); if(parentId == 0) { - parentId = main; + parentId = localMain; + if(parentId == 0) { + parentId = main; + } } + Post post; + try { + post = Post.LoadById(parentId); + } catch(NotFoundInDBException) { + throw new ApplicationException("Cannot find parent post #" + parentId); + } + post.Reply(user, title, body, layer, date, postId); } - Post post; - try { - post = Post.LoadById(parentId); - } catch(NotFoundInDBException) { - throw new ApplicationException("Cannot find parent post #" + parentId); - } - post.Reply(user, title, body, layer, date, postId); - } - Console.Write("+"); + Console.Write("+"); + })); } } catch(Exception e) { Console.Error.WriteLine("Cannot process post #" + postId + ": " + e.GetType().FullName + ": " + e.Message); @@ -257,9 +260,36 @@ namespace FLocal.ImportConsole { } Console.WriteLine("Not found discussions:"); + int j=0; + foreach(var insert in inserts) { + if(j%1000 == 0) { + Console.Write("[" + (int)(j/1000) + "]"); + } + try { + insert.Value(); + Console.Write("+"); + } catch(Exception e) { + Console.Error.WriteLine("Cannot process post #" + insert.Key + ": " + e.GetType().FullName + ": " + e.Message); + Console.Error.WriteLine(e.StackTrace); + Console.Write("!"); +// Console.ReadLine(); + } finally { + j++; + if((j%50000)==0) { + Core.RegistryCleaner.CleanRegistry(); + Core.RegistryCleaner.CleanRegistry(); + GC.Collect(); + Console.Error.WriteLine(); + Console.Error.WriteLine("Registry cleaned; garbage collected"); + Console.Error.WriteLine(); + } + } + } + foreach(int discussionId in discussionsIds.OrderBy(id => id)) { Console.WriteLine(discussionId); } + } }