cefile.cs

WINCE数据库sqlce 通讯stock 代码

							Field8="";
						else
							Field8=myReader.GetString(9);

						//写入记录
						sTemp=string.Concat("~",Field1,"|",Field2,"|",Field3,"|",Field4,"|",Field5,"|",Field6,"|",Field7,"|",Field8);
						sw.WriteLine(sTemp);

						//将导出的记录 标识置1
						mycmd.CommandText="update TAA set TAAAG=1 where TAAID="+myReader.GetValue(0);
						mycmd.ExecuteNonQuery();
						//提交事物
						//myTrans.Commit();
					}
					//提交事物
					myTrans.Commit();
				}
			}
			catch(Exception)
			{
				myTrans.Rollback();
				sw.Close();
				sTemp="";
				myReader.Close();
				conn.Dispose();
				return "error";
			}

			
			//临时字串清空
			sTemp="";
			try
			{
				sw.WriteLine("#T_AG");

				int RowCount=0;
				myReader=data.ExeSQL("select count(*) from TAB where TABAF=0");
				myReader.Read();
				RowCount=Int32.Parse(myReader.GetValue(0).ToString());
				if (RowCount>0)
				{
					myReader=data.ExeSQL("select * from TAB where TABAF=0");
			
					while(myReader.Read())
					{
						//T_AB_AA
						if(myReader.IsDBNull(1))
							Field1="";
						else
							Field1=myReader.GetString(1);
						//T_AB_AB
						if(myReader.IsDBNull(2))
							Field2="";
						else
							Field2=myReader.GetString(2);
						//T_AB_AC
						if(myReader.IsDBNull(3))
							Field3="";
						else
							Field3=myReader.GetString(3);
						//T_AB_AD
						Field4=myReader.GetDateTime(4).ToString();
						//T_AB_AE
						if(myReader.IsDBNull(5))
							Field5="";
						else
							Field5=myReader.GetString(5);
						//写入记录
				
						sTemp=string.Concat("~",Field1,"|",Field2,"|",Field3,"|",Field4,"|",Field5);
						sw.WriteLine(sTemp);

						//将导出的记录 标识置1
						mycmd.CommandText="update TAB set TABAF=1 where TABID="+myReader.GetValue(0);
						mycmd.ExecuteNonQuery();
					
					}
					myTrans.Commit();
				}				
			}
			catch(Exception)
			{
				myTrans.Rollback();
				sw.Close();
				sTemp="";
				myReader.Close();
				conn.Dispose();
				return "error";
			}

			sw.Close();
			myReader.Close();
			conn.Dispose();

			return FileName;
		}

		//将文件文件导入进数据库
		public bool TXT2DB(string FileName,bool Dciku)
		{
			CEData data=new CEData();
			SqlCeConnection conn=null;
			conn=data.conn;
			SqlCeTransaction myTrans;
			myTrans=conn.BeginTransaction();
			SqlCeCommand mycmd=conn.CreateCommand();
			mycmd.Connection=conn;
			mycmd.Transaction=myTrans;


			if(Dciku==true)
			{
				string sqltemp="";
				sqltemp="delete from TAC";
				data.ExeSQLNO(sqltemp);
				sqltemp="delete from TAD";
				data.ExeSQLNO(sqltemp);
				sqltemp="delete from TAE";
				data.ExeSQLNO(sqltemp);
			}

			StreamReader sr=new StreamReader(FileName,Encoding.GetEncoding("GB2312"));
			char[] sep=new char[]{'\n'};
			//存放表名
			string sTbName="";
			try
			{
				foreach(string s1 in sr.ReadToEnd().ToString().Split(sep))
				{
				
					//存放格式化的记录的数据
					ArrayList aRdName=new ArrayList();
					//清除记录中的数据
					aRdName.Clear();
					//读取表名
					if(s1.Substring(0,1)=="#")
					{
						sTbName=s1.Substring(1);

					}
					if(s1.Substring(0,1)=="~")
					{
						char[] sep2=new char[]{'|'};
						//读取记录中的数据
						foreach(string s2 in s1.Substring(1).Split(sep2))
						{
							aRdName.Add(s2);						
						}

						System.Collections.IEnumerator Et = aRdName.GetEnumerator();
						string sRecord1="";
						string sRecord2="";
						string sRecord3="";
						string sRecord4="";
						string sRecord5="";
						string sRecord6="";
						string sql="";
						//根据表名识别字段
						if(string.Compare(sTbName.Substring(0,3),"TAC",true)==0 && Dciku==true)
						{
							Et.Reset();
							Et.MoveNext();
							//第一个数据
							sRecord1=Et.Current.ToString();
							Et.MoveNext();
							//第二个
							sRecord2=Et.Current.ToString();
							Et.MoveNext();
							//第三个
							sRecord3=Et.Current.ToString();
							Et.MoveNext();
							//第四个
							sRecord4=Et.Current.ToString();
							sRecord4=sRecord4.Substring(0,sRecord4.Length-1);
	
							
							
							
							mycmd.CommandText="Insert into TAC(TACAA,TACAB,TACAC,TACAD) Values('"+sRecord1+"','"+sRecord2+"','"+sRecord3+"','"+sRecord4+"')";
							//执行插入记录
							mycmd.ExecuteNonQuery();
						}
						if(string.Compare(sTbName.Substring(0,3),"TAD",true)==0 && Dciku==true)
						{
							Et.Reset();
							Et.MoveNext();
							//第一个数据
							sRecord1=Et.Current.ToString();
							Et.MoveNext();
							//第二个
							sRecord2=Et.Current.ToString();
							sRecord2=sRecord2.Substring(0,sRecord2.Length-1);


							mycmd.CommandText="Insert into TAD(TADAA,TADAB) Values('"+sRecord1+"','"+sRecord2+"')";
							//执行插入记录
							mycmd.ExecuteNonQuery();
						}
					
						if(string.Compare(sTbName.Substring(0,3),"TAE",true)==0 && Dciku==true)
						{
							Et.Reset();
							Et.MoveNext();
							//第一个数据
							sRecord1=Et.Current.ToString();
							Et.MoveNext();
							//第二个
							sRecord2=Et.Current.ToString();
							Et.MoveNext();
							//第三个
							sRecord3=Et.Current.ToString();
							Et.MoveNext();
							//第四个(数值型)
							sRecord4=Et.Current.ToString();
							Et.MoveNext();
							//第五个
							sRecord5=Et.Current.ToString();
							Et.MoveNext();
							//第六个
							sRecord6=Et.Current.ToString();
							sRecord6=sRecord6.Substring(0,sRecord6.Length-1);


							mycmd.CommandText="Insert into TAE(TAEAA,TAEAB,TAEAC,TAEAD,TAEAE,TAEAF) Values('"+sRecord1+"','"+sRecord2+"','"+sRecord3+"','"+sRecord4+"',"+sRecord5+","+sRecord6+")";
							//执行插入记录
							mycmd.ExecuteNonQuery();
						}
						
						if(string.Compare(sTbName.Substring(0,3),"TAF",true)==0 && Dciku==false)
						{
							Et.Reset();
							Et.MoveNext();
							//第一个数据
							sRecord1=Et.Current.ToString();
							Et.MoveNext();
							//第二个(数值型)
							sRecord2=Et.Current.ToString();
							Et.MoveNext();
							//第三个
							sRecord3=Et.Current.ToString();
							Et.MoveNext();
							//第四个
							sRecord4=Et.Current.ToString();
							sRecord4=sRecord4.Substring(0,sRecord4.Length-1);

							//执行插入记录
							SqlCeDataReader myReader=null;
							sql="select * from TAF where TAFAA='"+sRecord1+"' and TAFAC='"+sRecord3+"'";
							myReader=data.ExeSQL(sql);
							if(myReader.Read())
							{
								sql="update TAF set TAFAB=TAFAB+"+sRecord2+" where TAFAA='"+sRecord1+"' and TAFAC='"+sRecord3+"'";
								data.ExeSQLNO(sql);


								//修改备注信息

								
								string sTemp=myReader.GetString(4);
			
								string[] sz1=sTemp.Split('^');
								string[] sz2=sRecord4.Split('^');
		
					
								string ss="";
								for(int i=0;i<sz2.Length;i++)
								{

									for(int j=0;j<sz1.Length;j++)
									{
										if(sz2[i]==sz1[j])
											break;

										if(sz2[i]!=sz1[j] && j==sz1.Length-1)
											ss=ss+sz2[i]+"^";
									}
								}
								ss=ss+sTemp;
								
								mycmd.CommandText="update TAF set TAFAD='"+ss+"'where TAFAA='"+sRecord1+"' and TAFAC='"+sRecord3+"'";
								mycmd.ExecuteNonQuery();

								

							}
							else
							{
								mycmd.CommandText="Insert into TAF(TAFAA,TAFAB,TAFAC,TAFAD) Values('"+sRecord1+"',"+sRecord2+",'"+sRecord3+"','"+sRecord4+"')";

								mycmd.ExecuteNonQuery();
							}
							

							myReader.Close();


						}
					  
					
					}

				}
				//提交事物
				myTrans.Commit();
			}
			catch(Exception)
			{
				myTrans.Rollback();
				//return false;

			}
			finally
			{
				sr.Close();
				conn.Dispose();
				
			}
			return true;
		}
	}
}