Add some alerts for taginfo

[chef.git] / cookbooks / mysql / libraries / mysql.rb

diff --git a/cookbooks/mysql/libraries/mysql.rb b/cookbooks/mysql/libraries/mysql.rb
index 7c45022fd4fc2b36980d0aa4753893d8240158e5..ec9743c946b964574cf8f8754c45435c7eed7b20 100644 (file)
--- a/cookbooks/mysql/libraries/mysql.rb
+++ b/cookbooks/mysql/libraries/mysql.rb
@@ -1,8 +1,8 @@
 require "chef/mixin/shell_out"
 require "rexml/document"
 
 require "chef/mixin/shell_out"
 require "rexml/document"
 

-class Chef
-  class MySQL
+module OpenStreetMap
+  module MySQL

     include Chef::Mixin::ShellOut
 
     USER_PRIVILEGES = [
     include Chef::Mixin::ShellOut
 
     USER_PRIVILEGES = [


@@ -20,7 +20,7 @@ class Chef
       :execute, :event, :trigger
     ].freeze
 
       :execute, :event, :trigger
     ].freeze
 

-    def execute(options)
+    def mysql_execute(options)

       # Create argument array
       args = []
 
       # Create argument array
       args = []
 


@@ -55,7 +55,7 @@ class Chef
 
     def query(sql, options = {})
       # Run the query
 
     def query(sql, options = {})
       # Run the query

-      result = execute(options.merge(:command => sql, :xml => true))
+      result = mysql_execute(options.merge(:command => sql, :xml => true))

 
       # Parse the output
       document = REXML::Document.new(result.stdout)
 
       # Parse the output
       document = REXML::Document.new(result.stdout)


@@ -84,8 +84,10 @@ class Chef
       records
     end
 
       records
     end
 

-    def users
-      @users ||= query("SELECT * FROM user").each_with_object({}) do |user, users|
+    def mysql_users
+      privilege_columns = USER_PRIVILEGES.collect { |privilege| "#{privilege}_priv" }.join(", ")
+
+      @mysql_users ||= query("SELECT user, host, #{privilege_columns} FROM user").each_with_object({}) do |user, users|

         name = "'#{user[:user]}'@'#{user[:host]}'"
 
         users[name] = USER_PRIVILEGES.each_with_object({}) do |privilege, privileges|
         name = "'#{user[:user]}'@'#{user[:host]}'"
 
         users[name] = USER_PRIVILEGES.each_with_object({}) do |privilege, privileges|


@@ -94,15 +96,15 @@ class Chef
       end
     end
 
       end
     end
 

-    def databases
-      @databases ||= query("SHOW databases").each_with_object({}) do |database, databases|
+    def mysql_databases
+      @mysql_databases ||= query("SHOW databases").each_with_object({}) do |database, databases|

         databases[database[:database]] = {
           :permissions => {}
         }
       end
 
       query("SELECT * FROM db").each do |record|
         databases[database[:database]] = {
           :permissions => {}
         }
       end
 
       query("SELECT * FROM db").each do |record|

-        database = @databases[record[:db]]
+        database = @mysql_databases[record[:db]]

 
         next unless database
 
 
         next unless database
 


@@ -113,10 +115,10 @@ class Chef
         end
       end
 
         end
       end
 

-      @databases
+      @mysql_databases

     end
 
     end
 

-    def canonicalise_user(user)
+    def mysql_canonicalise_user(user)

       local, host = user.split("@")
 
       host ||= "%"
       local, host = user.split("@")
 
       host ||= "%"


@@ -127,10 +129,16 @@ class Chef
       "#{local}@#{host}"
     end
 
       "#{local}@#{host}"
     end
 

-    def privilege_name(privilege)
+    def mysql_privilege_name(privilege)

       case privilege
       when :grant
         "GRANT OPTION"
       case privilege
       when :grant
         "GRANT OPTION"

+      when :show_db
+        "SHOW DATABASES"
+      when :repl_slave
+        "REPLICATION SLAVE"
+      when :repl_client
+        "REPLICATION CLIENT"

       when :create_tmp_table
         "CREATE TEMPORARY TABLES"
       else
       when :create_tmp_table
         "CREATE TEMPORARY TABLES"
       else