##// END OF EJS Templates
jro_apps » redmine
RSS
Removes hardcoded table names in Repository#clear_changesets....
Jean-Philippe Lang -
r2619:3704653c7aca
parent child
Show More
Side by Side Unified
Context file:
r2619:3704653c7aca Loading diff...:
Show file before | Show file after | Hide comments
@@ -1,180 +1,181
1 1 # redMine - project management software
2 2 # Copyright (C) 2006-2007 Jean-Philippe Lang
3 3 #
4 4 # This program is free software; you can redistribute it and/or
5 5 # modify it under the terms of the GNU General Public License
6 6 # as published by the Free Software Foundation; either version 2
7 7 # of the License, or (at your option) any later version.
8 8 #
9 9 # This program is distributed in the hope that it will be useful,
10 10 # but WITHOUT ANY WARRANTY; without even the implied warranty of
11 11 # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
12 12 # GNU General Public License for more details.
13 13 #
14 14 # You should have received a copy of the GNU General Public License
15 15 # along with this program; if not, write to the Free Software
16 16 # Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
17 17
18 18 class Repository < ActiveRecord::Base
19 19 belongs_to :project
20 20 has_many :changesets, :order => "#{Changeset.table_name}.committed_on DESC, #{Changeset.table_name}.id DESC"
21 21 has_many :changes, :through => :changesets
22 22
23 23 # Raw SQL to delete changesets and changes in the database
24 24 # has_many :changesets, :dependent => :destroy is too slow for big repositories
25 25 before_destroy :clear_changesets
26 26
27 27 # Checks if the SCM is enabled when creating a repository
28 28 validate_on_create { |r| r.errors.add(:type, :invalid) unless Setting.enabled_scm.include?(r.class.name.demodulize) }
29 29
30 30 # Removes leading and trailing whitespace
31 31 def url=(arg)
32 32 write_attribute(:url, arg ? arg.to_s.strip : nil)
33 33 end
34 34
35 35 # Removes leading and trailing whitespace
36 36 def root_url=(arg)
37 37 write_attribute(:root_url, arg ? arg.to_s.strip : nil)
38 38 end
39 39
40 40 def scm
41 41 @scm ||= self.scm_adapter.new url, root_url, login, password
42 42 update_attribute(:root_url, @scm.root_url) if root_url.blank?
43 43 @scm
44 44 end
45 45
46 46 def scm_name
47 47 self.class.scm_name
48 48 end
49 49
50 50 def supports_cat?
51 51 scm.supports_cat?
52 52 end
53 53
54 54 def supports_annotate?
55 55 scm.supports_annotate?
56 56 end
57 57
58 58 def entry(path=nil, identifier=nil)
59 59 scm.entry(path, identifier)
60 60 end
61 61
62 62 def entries(path=nil, identifier=nil)
63 63 scm.entries(path, identifier)
64 64 end
65 65
66 66 def properties(path, identifier=nil)
67 67 scm.properties(path, identifier)
68 68 end
69 69
70 70 def cat(path, identifier=nil)
71 71 scm.cat(path, identifier)
72 72 end
73 73
74 74 def diff(path, rev, rev_to)
75 75 scm.diff(path, rev, rev_to)
76 76 end
77 77
78 78 # Default behaviour: we search in cached changesets
79 79 def changesets_for_path(path, options={})
80 80 path = "/#{path}" unless path.starts_with?('/')
81 81 Change.find(:all, :include => {:changeset => :user},
82 82 :conditions => ["repository_id = ? AND path = ?", id, path],
83 83 :order => "committed_on DESC, #{Changeset.table_name}.id DESC",
84 84 :limit => options[:limit]).collect(&:changeset)
85 85 end
86 86
87 87 # Returns a path relative to the url of the repository
88 88 def relative_path(path)
89 89 path
90 90 end
91 91
92 92 def latest_changeset
93 93 @latest_changeset ||= changesets.find(:first)
94 94 end
95 95
96 96 def scan_changesets_for_issue_ids
97 97 self.changesets.each(&:scan_comment_for_issue_ids)
98 98 end
99 99
100 100 # Returns an array of committers usernames and associated user_id
101 101 def committers
102 102 @committers ||= Changeset.connection.select_rows("SELECT DISTINCT committer, user_id FROM #{Changeset.table_name} WHERE repository_id = #{id}")
103 103 end
104 104
105 105 # Maps committers username to a user ids
106 106 def committer_ids=(h)
107 107 if h.is_a?(Hash)
108 108 committers.each do |committer, user_id|
109 109 new_user_id = h[committer]
110 110 if new_user_id && (new_user_id.to_i != user_id.to_i)
111 111 new_user_id = (new_user_id.to_i > 0 ? new_user_id.to_i : nil)
112 112 Changeset.update_all("user_id = #{ new_user_id.nil? ? 'NULL' : new_user_id }", ["repository_id = ? AND committer = ?", id, committer])
113 113 end
114 114 end
115 115 @committers = nil
116 116 true
117 117 else
118 118 false
119 119 end
120 120 end
121 121
122 122 # Returns the Redmine User corresponding to the given +committer+
123 123 # It will return nil if the committer is not yet mapped and if no User
124 124 # with the same username or email was found
125 125 def find_committer_user(committer)
126 126 if committer
127 127 c = changesets.find(:first, :conditions => {:committer => committer}, :include => :user)
128 128 if c && c.user
129 129 c.user
130 130 elsif committer.strip =~ /^([^<]+)(<(.*)>)?$/
131 131 username, email = $1.strip, $3
132 132 u = User.find_by_login(username)
133 133 u ||= User.find_by_mail(email) unless email.blank?
134 134 u
135 135 end
136 136 end
137 137 end
138 138
139 139 # fetch new changesets for all repositories
140 140 # can be called periodically by an external script
141 141 # eg. ruby script/runner "Repository.fetch_changesets"
142 142 def self.fetch_changesets
143 143 find(:all).each(&:fetch_changesets)
144 144 end
145 145
146 146 # scan changeset comments to find related and fixed issues for all repositories
147 147 def self.scan_changesets_for_issue_ids
148 148 find(:all).each(&:scan_changesets_for_issue_ids)
149 149 end
150 150
151 151 def self.scm_name
152 152 'Abstract'
153 153 end
154 154
155 155 def self.available_scm
156 156 subclasses.collect {|klass| [klass.scm_name, klass.name]}
157 157 end
158 158
159 159 def self.factory(klass_name, *args)
160 160 klass = "Repository::#{klass_name}".constantize
161 161 klass.new(*args)
162 162 rescue
163 163 nil
164 164 end
165 165
166 166 private
167 167
168 168 def before_save
169 169 # Strips url and root_url
170 170 url.strip!
171 171 root_url.strip!
172 172 true
173 173 end
174 174
175 175 def clear_changesets
176 connection.delete("DELETE FROM changes WHERE changes.changeset_id IN (SELECT changesets.id FROM changesets WHERE changesets.repository_id = #{id})")
177 connection.delete("DELETE FROM changesets_issues WHERE changesets_issues.changeset_id IN (SELECT changesets.id FROM changesets WHERE changesets.repository_id = #{id})")
178 connection.delete("DELETE FROM changesets WHERE changesets.repository_id = #{id}")
176 cs, ch, ci = Changeset.table_name, Change.table_name, "#{table_name_prefix}changesets_issues#{table_name_suffix}"
177 connection.delete("DELETE FROM #{ch} WHERE #{ch}.changeset_id IN (SELECT #{cs}.id FROM #{cs} WHERE #{cs}.repository_id = #{id})")
178 connection.delete("DELETE FROM #{ci} WHERE #{ci}.changeset_id IN (SELECT #{cs}.id FROM #{cs} WHERE #{cs}.repository_id = #{id})")
179 connection.delete("DELETE FROM #{cs} WHERE #{cs}.repository_id = #{id}")
179 180 end
180 181 end
General Comments 0
You need to be logged in to leave comments. Login now