Skip to content

Commit 6a4471e

Browse files
committed
Changed SqlKataRepositories in such way that constants are now used instead of string literals when referencing column/table names
1 parent 9d56dbb commit 6a4471e

File tree

3 files changed

+7
-7
lines changed

3 files changed

+7
-7
lines changed

Repository/SqlKataMarketOrderRepository.cs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,7 @@ public class SqlKataMarketOrderRepository : SqlKataRepository<MarketOrder>, IMar
1111
{
1212
private const int DecimalPrecision = 100000000;
1313

14-
public SqlKataMarketOrderRepository(SqlKataDatabase db) : base(db, "market_orders")
14+
public SqlKataMarketOrderRepository(SqlKataDatabase db) : base(db, SqlSchema.TableMarketOrders)
1515
{
1616
}
1717

@@ -36,9 +36,9 @@ public override MarketOrder FromRow(dynamic d) =>
3636
(int) d.id, (int) d.portfolio_entry_id);
3737

3838
public List<MarketOrder> GetAllByPortfolioEntryId(int portfolioEntryId) =>
39-
RowsToObjects(Db.Get().Query(tableName).Where("portfolio_entry_id", portfolioEntryId).Get());
39+
RowsToObjects(Db.Get().Query(tableName).Where(SqlSchema.MarketOrdersPortfolioEntryId, portfolioEntryId).Get());
4040

4141
public int DeletePortfolioEntryOrders(int portfolioEntryOrder) =>
42-
Db.Get().Query(tableName).Where("portfolio_entry_id", portfolioEntryOrder).Delete();
42+
Db.Get().Query(tableName).Where(SqlSchema.MarketOrdersPortfolioEntryId, portfolioEntryOrder).Delete();
4343
}
4444
}

Repository/SqlKataPortfolioEntryRepository.cs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,7 @@ namespace Repository
77
{
88
public class SqlKataPortfolioEntryRepository : SqlKataRepository<PortfolioEntry>, IPortfolioEntryRepository
99
{
10-
public SqlKataPortfolioEntryRepository(SqlKataDatabase db) : base(db, "portfolio_entries")
10+
public SqlKataPortfolioEntryRepository(SqlKataDatabase db) : base(db, SqlSchema.TablePortfolioEntries)
1111
{
1212
}
1313

@@ -22,9 +22,9 @@ public SqlKataPortfolioEntryRepository(SqlKataDatabase db) : base(db, "portfolio
2222
public override PortfolioEntry FromRow(dynamic d) => new((string) d.symbol, (int) d.portfolio_id, (int) d.id);
2323

2424
public List<PortfolioEntry> GetAllByPortfolioId(int portfolioId) =>
25-
RowsToObjects(Db.Get().Query(tableName).Where("portfolio_id", portfolioId).Get());
25+
RowsToObjects(Db.Get().Query(tableName).Where(SqlSchema.PortfolioEntriesPortfolioId, portfolioId).Get());
2626

2727
public int DeletePortfolioEntries(int portfolioId) =>
28-
Db.Get().Query(tableName).Where("portfolio_id", portfolioId).Delete();
28+
Db.Get().Query(tableName).Where(SqlSchema.PortfolioEntriesPortfolioId, portfolioId).Delete();
2929
}
3030
}

Repository/SqlKataPortfolioRepository.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,7 @@ namespace Repository
55
{
66
public class SqlKataPortfolioRepository : SqlKataRepository<Portfolio>, IPortfolioRepository
77
{
8-
public SqlKataPortfolioRepository(SqlKataDatabase db) : base(db, "portfolios")
8+
public SqlKataPortfolioRepository(SqlKataDatabase db) : base(db, SqlSchema.TablePortfolios)
99
{
1010
}
1111

0 commit comments

Comments
 (0)