mirror of
https://github.com/anjoy8/Blog.Core.git
synced 2024-09-20 23:48:27 +08:00
fix bug #165
This commit is contained in:
parent
822e3af838
commit
a26cf8e116
|
@ -73,12 +73,19 @@ namespace Blog.Core.Model.Seed
|
||||||
|
|
||||||
Console.WriteLine();
|
Console.WriteLine();
|
||||||
|
|
||||||
|
|
||||||
// 创建数据库
|
// 创建数据库
|
||||||
Console.WriteLine($"Create Database(The Db Id:{MyContext.ConnId})...");
|
Console.WriteLine($"Create Database(The Db Id:{MyContext.ConnId})...");
|
||||||
myContext.Db.DbMaintenance.CreateDatabase();
|
|
||||||
ConsoleHelper.WriteSuccessLine($"Database created successfully!");
|
|
||||||
|
|
||||||
|
if (MyContext.DbType != SqlSugar.DbType.Oracle)
|
||||||
|
{
|
||||||
|
myContext.Db.DbMaintenance.CreateDatabase();
|
||||||
|
ConsoleHelper.WriteSuccessLine($"Database created successfully!");
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
//Oracle 数据库不支持该操作
|
||||||
|
ConsoleHelper.WriteSuccessLine($"Oracle 数据库不支持该操作,可手动创建Oracle数据库!");
|
||||||
|
}
|
||||||
|
|
||||||
// 创建数据库表,遍历指定命名空间下的class,
|
// 创建数据库表,遍历指定命名空间下的class,
|
||||||
// 注意不要把其他命名空间下的也添加进来。
|
// 注意不要把其他命名空间下的也添加进来。
|
||||||
|
|
|
@ -18,7 +18,7 @@ namespace Blog.Core.Repository.MongoRepository
|
||||||
|
|
||||||
public async Task AddAsync(TEntity entity)
|
public async Task AddAsync(TEntity entity)
|
||||||
{
|
{
|
||||||
await _context.Db.GetCollection<TEntity>(nameof(TEntity))
|
await _context.Db.GetCollection<TEntity>(typeof(TEntity).Name)
|
||||||
.InsertOneAsync(entity);
|
.InsertOneAsync(entity);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -26,14 +26,14 @@ namespace Blog.Core.Repository.MongoRepository
|
||||||
{
|
{
|
||||||
var filter = Builders<TEntity>.Filter.Eq("Id", Id);
|
var filter = Builders<TEntity>.Filter.Eq("Id", Id);
|
||||||
|
|
||||||
return await _context.Db.GetCollection<TEntity>(nameof(TEntity))
|
return await _context.Db.GetCollection<TEntity>(typeof(TEntity).Name)
|
||||||
.Find(filter)
|
.Find(filter)
|
||||||
.FirstOrDefaultAsync();
|
.FirstOrDefaultAsync();
|
||||||
}
|
}
|
||||||
|
|
||||||
public async Task<List<TEntity>> GetListAsync()
|
public async Task<List<TEntity>> GetListAsync()
|
||||||
{
|
{
|
||||||
return await _context.Db.GetCollection<TEntity>(nameof(TEntity))
|
return await _context.Db.GetCollection<TEntity>(typeof(TEntity).Name)
|
||||||
.Find(new BsonDocument())
|
.Find(new BsonDocument())
|
||||||
.ToListAsync();
|
.ToListAsync();
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue
Block a user