1 //插入新数据
2  public void insert(Orders item)
3 {
4 Database db=DbUtility.getDatabase();
5  //以下为生成的insert语句
6  string sql=@"insert into Orders (
7 OrderID,CustomerID,EmployeeID,OrderDate,RequiredDate,ShippedDate,ShipVia,Freight,ShipName,ShipAddress,ShipCity,ShipRegion,ShipPostalCode,ShipCountry)
8 values (
9 @OrderID,@CustomerID,@EmployeeID,@OrderDate,@RequiredDate,@ShippedDate,@ShipVia,@Freight,@ShipName,@ShipAddress,@ShipCity,@ShipRegion,@ShipPostalCode,@ShipCountry)";
10 DbCommand command=db.GetSqlStringCommand(sql);
11  //为数据库命令添加参数
12  db.AddInParameter(command,"@OrderID",DbType.Int32,item.OrderID);
13 db.AddInParameter(command,"@CustomerID",DbType.String,item.CustomerID);
14 db.AddInParameter(command,"@EmployeeID",DbType.Int32,item.EmployeeID);
15 db.AddInParameter(command,"@OrderDate",DbType.DateTime,item.OrderDate);
16 db.AddInParameter(command,"@RequiredDate",DbType.DateTime,item.RequiredDate);
17 db.AddInParameter(command,"@ShippedDate",DbType.DateTime,item.ShippedDate);
18 db.AddInParameter(command,"@ShipVia",DbType.Int32,item.ShipVia);
19 db.AddInParameter(command,"@Freight",DbType.Decimal,item.Freight);
20 db.AddInParameter(command,"@ShipName",DbType.String,item.ShipName);
21 db.AddInParameter(command,"@ShipAddress",DbType.String,item.ShipAddress);
22 db.AddInParameter(command,"@ShipCity",DbType.String,item.ShipCity);
23 db.AddInParameter(command,"@ShipRegion",DbType.String,item.ShipRegion);
24 db.AddInParameter(command,"@ShipPostalCode",DbType.String,item.ShipPostalCode);
25 db.AddInParameter(command,"@ShipCountry",DbType.String,item.ShipCountry);
26 db.ExecuteNonQuery(command);
27 command.Dispose();
28 }

1
2  //生成insert的sql语句
3  private string getInsertSql()
4 {
5 StringBuilder sb = new StringBuilder();
6 string temp = null;
7 temp = "insert into " + table + " ( ";
8 sb.Append(temp+ Environment.NewLine);
9 //添加各列
10   foreach (string n in columnNames)
11 {
12 sb.Append(n + ",");
13 }
14 //去掉最后一个逗号
15   sb.Remove(sb.Length - 1, 1);
16 temp = ")" + Environment.NewLine + " values (" + Environment.NewLine;
17 sb.Append(temp);
18 //添加各个参数
19   foreach (string n in columnNames)
20 {
21 sb.Append("@" + n + ",");
22 }
23 //去掉最后一个逗号
24   sb.Remove(sb.Length - 1, 1);
25 sb.Append(")");
26 return sb.ToString();
27 }

1 //生成数据访问类insert方法代码
2  public string generateInsertMethod()
3 {
4 StringBuilder sb = new StringBuilder();
5 string temp = null;
6 temp = "//插入新数据";
7 sb.Append(temp + Environment.NewLine);
8 temp = "public void insert(" + table + " item)";
9 sb.Append(temp + Environment.NewLine);
10 sb.Append("{" + Environment.NewLine);
11 temp = "Database db=DbUtility.getDatabase();";
12 sb.Append(temp + Environment.NewLine);
13 temp = "//以下为生成的insert语句";
14 sb.Append(temp + Environment.NewLine);
15 temp = "string sql=@\"" + getInsertSql() + "\";";
16 sb.Append(temp + Environment.NewLine);
17 temp="DbCommand command=db.GetSqlStringCommand(sql);";
18 sb.Append(temp + Environment.NewLine);
19 temp = "//为数据库命令添加参数";
20 sb.Append(temp + Environment.NewLine);
21 temp = getAddParameterCode();
22 sb.Append(temp);
23 temp = "db.ExecuteNonQuery(command);";
24 sb.Append(temp + Environment.NewLine);
25 temp = "command.Dispose();";
26 sb.Append(temp + Environment.NewLine);
27 sb.Append("}" + Environment.NewLine);
28 return sb.ToString();
29 }

1 private string getAddParameterCode()
2 {
3 return getAddParameterCode(allColumns);
4 }
5  /// <summary>
6  /// 生成向DbCommand添加参数的语句
7  /// </summary>
8  /// <param name="columns">要添加参数的列（每列添加一个参数）</param>
9  /// <returns>生成的代码</returns>
10  private string getAddParameterCode(DataColumn[] columns)
11 {
12 StringBuilder sb = new StringBuilder();
13 string temp=null;
14 foreach (DataColumn c in columns)
15 {
16 temp = "db.AddInParameter(command,\"@" + c.ColumnName + "\",DbType." + c.DataType.Name + ",item." + c.ColumnName + ");";
17 sb.Append(temp);
18 sb.Append(Environment.NewLine);
19 }
20 return sb.ToString();
21 }