FilesExpand file tree

 master

/

SqlQueryBuilder.cs

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

48 lines (42 loc) · 1.43 KB

 master

/

SqlQueryBuilder.cs

Top

File metadata and controls

• Code
• Blame

48 lines (42 loc) · 1.43 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

using System.Collections.Generic;

using System.Linq;

using Simple.Data.Ado;

namespace Simple.Data.SqlServer

{

public class SqlQueryBuilder : QueryBuilderBase

{

private List<SimpleQueryClauseBase> _unhandledClauses;

public SqlQueryBuilder(AdoAdapter adapter, int bulkIndex)

: base(adapter, bulkIndex)

{

}

public override ICommandBuilder Build(SimpleQuery query, out IEnumerable<SimpleQueryClauseBase> unhandledClauses)

{

_unhandledClauses = new List<SimpleQueryClauseBase>();

SetQueryContext(query);

HandleJoins();

HandleQueryCriteria();

HandleGrouping();

HandleHavingCriteria();

HandleOrderBy();

unhandledClauses = _unhandledClauses;

return _commandBuilder;

}

protected override string GetSelectClause(ObjectName tableName)

{

var select = base.GetSelectClause(tableName);

var forUpdateClause = _query.Clauses.OfType<ForUpdateClause>().FirstOrDefault();

if (forUpdateClause != null)

{

var forUpdate = " WITH (UPDLOCK, ROWLOCK";

if (forUpdateClause.SkipLockedRows)

{

forUpdate += ", READPAST";

}

forUpdate += ")";

select += forUpdate;

}

return select;

}

}

}