Skip to content

Commit c38001f

Browse files
fix(jira): use Jira created timestamp and inner join for changelog convertor (#8834)
1 parent 61d66a1 commit c38001f

1 file changed

Lines changed: 8 additions & 7 deletions

File tree

backend/plugins/jira/tasks/issue_changelog_convertor.go

Lines changed: 8 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -95,16 +95,17 @@ func ConvertIssueChangelogs(subtaskCtx plugin.SubTaskContext) errors.Error {
9595
_tool_jira_issue_changelogs.connection_id = _tool_jira_issue_changelog_items.connection_id
9696
AND _tool_jira_issue_changelogs.changelog_id = _tool_jira_issue_changelog_items.changelog_id
9797
)`),
98-
dal.Join(`left join _tool_jira_board_issues on (
99-
_tool_jira_board_issues.connection_id = _tool_jira_issue_changelogs.connection_id
100-
AND _tool_jira_board_issues.issue_id = _tool_jira_issue_changelogs.issue_id
101-
)`),
102-
dal.Where("_tool_jira_issue_changelog_items.connection_id = ? AND _tool_jira_board_issues.board_id = ?", connectionId, boardId),
103-
}
98+
dal.Join(`inner join _tool_jira_board_issues on (
99+
_tool_jira_board_issues.connection_id = _tool_jira_issue_changelogs.connection_id
100+
AND _tool_jira_board_issues.issue_id = _tool_jira_issue_changelogs.issue_id
101+
AND _tool_jira_board_issues.board_id = ?
102+
)`, boardId),
103+
dal.Where("_tool_jira_issue_changelog_items.connection_id = ?", connectionId), }
104104
if stateManager.IsIncremental() {
105105
since := stateManager.GetSince()
106106
if since != nil {
107-
clauses = append(clauses, dal.Where("_tool_jira_issue_changelog_items.created_at >= ? ", since))
107+
clauses = append(clauses, dal.Where("_tool_jira_issue_changelogs.created >= ?", since))
108+
108109
}
109110
}
110111
return db.Cursor(clauses...)

0 commit comments

Comments
 (0)