table.cs

可以自动生成一些应用代码

                if (field.FieldType.Equals("2")) //dataType = "int";
                {
                    sw.WriteLine(TableName + "." + field.FieldName + "=" + "int.Parse (DataReader[\"" + field.FieldName + "\"].ToString());");

                }
                i++;
                             
            }
            sw.WriteLine(" Arr" + TableName + ".Add("+TableName +");");
            sw.WriteLine("}");
            sw.WriteLine("DataReader.Close();");
            sw.WriteLine("ConDB.Close();");
            sw.WriteLine(" return Arr"+TableName +";");
            sw.WriteLine("}");

            //FIND ALL 函数创建完毕--------------------------------------------------------------------------------------------------------------

          
            
            //创建FindByPK函数---------------------------------------------------------------------------------------


            sw.WriteLine("public ArrayList  Find" + TableName + "ByPK(Int32 "+ PrimaryKey+")");
            sw.WriteLine("{");
            sw.WriteLine(" String SQL;");
            sw.WriteLine("SQL = \"select * from " + TableName + " where "+PrimaryKey +"=\" +"+PrimaryKey+".ToString();");
            sw.WriteLine("ArrayList Arr" + TableName + " = new ArrayList();");
            sw.WriteLine("DbCommand = new OleDbCommand(SQL, ConDB);");
            sw.WriteLine("DbCommand.Connection.Open();");
            sw.WriteLine("DataReader = DbCommand.ExecuteReader();");
            sw.WriteLine("while (DataReader.Read())");
            sw.WriteLine("{");
            sw.WriteLine(TableName + " " + TableName + " = new " + TableName + "();");
             i = 0;
            foreach (Field field in Fields)//遍历每一个字段
            {

                String dataType = "";

                //student.age = (int.Parse)(DataReader["age"].ToString());

                sw.WriteLine("if (DataReader[\"" + field.FieldName + "\"] != DBNull.Value)");
                if (field.FieldType.Equals("130") || field.FieldType.Equals("7")) //dataType = "String";
                {
                    sw.WriteLine(TableName + "." + field.FieldName + "=" + "DataReader[\"" + field.FieldName + "\"].ToString();");

                }

                if (field.FieldType.Equals("3")) //dataType = "long int ";
                {
                    sw.WriteLine(TableName + "." + field.FieldName + "=" + "Int32.Parse(DataReader[\"" + field.FieldName + "\"].ToString());");

                }
                if (field.FieldType.Equals("4") || field.FieldType.Equals("5")) //dataType = "float 4";
                {
                    sw.WriteLine(TableName + "." + field.FieldName + "=" + " float.Parse (DataReader[\"" + field.FieldName + "\"].ToString());");

                }
                if (field.FieldType.Equals("2")) //dataType = "int";
                {
                    sw.WriteLine(TableName + "." + field.FieldName + "=" + "int.Parse (DataReader[\"" + field.FieldName + "\"].ToString());");

                }
                i++;

            }
            sw.WriteLine(" Arr" + TableName + ".Add(" + TableName + ");");
            sw.WriteLine("}");
            sw.WriteLine("DataReader.Close();");
            sw.WriteLine("ConDB.Close();");
            sw.WriteLine(" return Arr" + TableName + ";");
            sw.WriteLine("}");

            //FIND ALL by id 函数创建完毕--------------------------------------------------------------------------------------------------------------



            //创建插入函数------------------------------------------------------------------
            sw.WriteLine("public Boolean  Add" + TableName + "("+TableName +"  "+TableName+")");
            sw.WriteLine("{");
            sw.WriteLine(" String SQL;");
            String SQL = "";
            sw.WriteLine("try");
            sw.WriteLine("{");

            SQL = "SQL = \"insert into " + TableName + " (";
            int count = Fields.Count;//获得表中字段的数目
            int currentFieldOrder = 0;//当前字段编号
            foreach (Field field in Fields)//遍历每一个字段
            {
                currentFieldOrder++;
                if (field.FieldName.Equals(PrimaryKey)) continue;//如果是主键则不添加
                SQL = SQL +"["+ field.FieldName+"]";
                if (currentFieldOrder!=count) SQL = SQL + ",";
            }
            
            SQL = SQL + ") values (";
            currentFieldOrder = 0;
            foreach (Field field in Fields)//遍历每一个对象属性字段
            {
               
                currentFieldOrder++;
                if (field.FieldName.Equals(PrimaryKey )) continue;
                SQL = SQL + "@" + field.FieldName;
                if (currentFieldOrder != count) SQL = SQL + ",";
            }
            SQL = SQL + ")\";";
            sw.WriteLine(SQL);

           
            sw.WriteLine( "DbCommand = new OleDbCommand(SQL, ConDB);");
            sw.WriteLine( "DbCommand.Connection.Open();");
            foreach (Field field in Fields)//遍历每一个对象属性字段
            {
                 if (field.FieldName.Equals(PrimaryKey)) continue;
                 sw.WriteLine("if( "+TableName +"."+ field.FieldName + "!=null)");
                 sw.WriteLine("DbCommand.Parameters.Add(\"@"+ field.FieldName +"\", "+TableName+"."+field.FieldName +");");
                 sw.WriteLine("else");
                 sw.WriteLine("DbCommand.Parameters.Add(\"@" + field.FieldName + "\", " + "DBNull.Value);");
            }
            sw.WriteLine("  DataReader = DbCommand.ExecuteReader();");
            sw.WriteLine(" DataReader.Close();");
            sw.WriteLine("ConDB.Close();");
            sw.WriteLine("return true ;");
            sw.WriteLine("}");
            sw.WriteLine(" catch (System.Exception ex)");
            sw.WriteLine("{");
            sw.WriteLine("return false ;");
            sw.WriteLine("}");
            sw.WriteLine("}");
         

            //创建插入函数完毕------------------------------------------------------------



            //创建删除函数------------------------------------------------------------------------
            sw.WriteLine("public Boolean  Del" + TableName + "ByPK(Int32 "+ PrimaryKey+")");
            sw.WriteLine("{");
            sw.WriteLine(" String SQL;");
          
           // sw.WriteLine("try");
            //sw.WriteLine("{");

            SQL = "SQL = \"delete from " + TableName + " where "+ PrimaryKey +"=@"+PrimaryKey ;
          
           

            SQL = SQL + "\";";
    
            sw.WriteLine(SQL);


            sw.WriteLine("DbCommand = new OleDbCommand(SQL, ConDB);");
            sw.WriteLine("DbCommand.Connection.Open();");
           // foreach (Field field in Fields)//遍历每一个对象属性字段
           // {
           //     if (field.FieldName.Equals("id")) 
                sw.WriteLine("DbCommand.Parameters.Add(\"@" + PrimaryKey  + "\", " +PrimaryKey  + ");");
           // }
            sw.WriteLine("  DataReader = DbCommand.ExecuteReader();");
            sw.WriteLine(" if (DataReader.RecordsAffected==1)");
             sw.WriteLine("{");
             sw.WriteLine("    DataReader.Close();");
             sw.WriteLine("    ConDB.Close();");
             sw.WriteLine("    return true;");
            sw.WriteLine(" }");
             sw.WriteLine("else");
            sw.WriteLine(" {");
            sw.WriteLine("     DataReader.Close();");
              sw.WriteLine("   ConDB.Close();");
             sw.WriteLine("    return false;");
             sw.WriteLine("}");

             sw.WriteLine("}");

            //创建删除函数完毕





             //创建更新函数
             sw.WriteLine("public Boolean  Update" + TableName + "(" + TableName + "  " + TableName + ")");
             sw.WriteLine("{");
             sw.WriteLine(" String SQL;");
             
           

             SQL = "SQL = \"update  " + TableName + "  set  ";

             currentFieldOrder = 0;
             foreach (Field field in Fields)//遍历每一个对象属性字段
             {

                 currentFieldOrder++;
                 if (field.FieldName.Equals(PrimaryKey )) continue;
                 SQL = SQL +"["+ field.FieldName+"]=@" + field.FieldName;
                 if (currentFieldOrder != count) SQL = SQL + ",";
             }
             SQL = SQL + "  where "+PrimaryKey+"=@"+PrimaryKey +"\";";
             sw.WriteLine(SQL);
             sw.WriteLine("DbCommand = new OleDbCommand(SQL, ConDB);");
             sw.WriteLine("DbCommand.Connection.Open();");
             foreach (Field field in Fields)//遍历每一个对象属性字段
             {
                 if (field.FieldName.Equals(PrimaryKey)) continue;
                 sw.WriteLine("if(" +TableName +"."+ field.FieldName + "!=null)");
                 sw.WriteLine("DbCommand.Parameters.Add(\"@" + field.FieldName + "\", " + TableName + "." + field.FieldName + ");");
                 sw.WriteLine("else");
                 sw.WriteLine("DbCommand.Parameters.Add(\"@" + field.FieldName + "\", " + "DBNull.Value);");
             }
             sw.WriteLine("DbCommand.Parameters.Add(\"@" + PrimaryKey + "\", " + TableName + "." +PrimaryKey + ");");
             sw.WriteLine("  DataReader = DbCommand.ExecuteReader();");
             sw.WriteLine(" if (DataReader.RecordsAffected==1)");
             sw.WriteLine("{");
             sw.WriteLine("    DataReader.Close();");
             sw.WriteLine("    ConDB.Close();");
             sw.WriteLine("    return true;");
             sw.WriteLine(" }");
             sw.WriteLine("else");
             sw.WriteLine(" {");
             sw.WriteLine("     DataReader.Close();");
             sw.WriteLine("   ConDB.Close();");
             sw.WriteLine("    return false;");
             sw.WriteLine("}");

             sw.WriteLine("}");


             //创建更新函数完毕

            sw.WriteLine("}");
            sw.WriteLine("}");
            sw.WriteLine("\n" );
            sw.Close();
            fs.Close();
            return true;


        }
    }
}