5695cef4a6
Default mysqld_type return value should be "mysql" if another type is not detected. Returning nil breaks mysql 5.7.11 on Ubuntu (at least) due to the conditional used in mysql_user provider.
109 lines
2.8 KiB
Ruby
109 lines
2.8 KiB
Ruby
class Puppet::Provider::Mysql < Puppet::Provider
|
|
|
|
# Without initvars commands won't work.
|
|
initvars
|
|
|
|
# Make sure we find mysqld on CentOS
|
|
ENV['PATH']=ENV['PATH'] + ':/usr/libexec'
|
|
|
|
commands :mysql => 'mysql'
|
|
commands :mysqld => 'mysqld'
|
|
commands :mysqladmin => 'mysqladmin'
|
|
|
|
# Optional defaults file
|
|
def self.defaults_file
|
|
if File.file?("#{Facter.value(:root_home)}/.my.cnf")
|
|
"--defaults-extra-file=#{Facter.value(:root_home)}/.my.cnf"
|
|
else
|
|
nil
|
|
end
|
|
end
|
|
|
|
def self.mysqld_type
|
|
# find the mysql "dialect" like mariadb / mysql etc.
|
|
mysqld_version_string.scan(/mariadb/i) { return "mariadb" }
|
|
mysqld_version_string.scan(/\s\(mysql/i) { return "mysql" }
|
|
mysqld_version_string.scan(/\s\(percona/i) { return "percona" }
|
|
return "mysql"
|
|
end
|
|
|
|
def mysqld_type
|
|
self.class.mysqld_type
|
|
end
|
|
|
|
def self.mysqld_version_string
|
|
# we cache the result ...
|
|
return @mysqld_version_string unless @mysqld_version_string.nil?
|
|
@mysqld_version_string = mysqld(['-V'].compact)
|
|
return @mysqld_version_string
|
|
end
|
|
|
|
def mysqld_version_string
|
|
self.class.mysqld_version_string
|
|
end
|
|
|
|
def self.mysqld_version
|
|
# note: be prepared for '5.7.6-rc-log' etc results
|
|
# versioncmp detects 5.7.6-log to be newer then 5.7.6
|
|
# this is why we need the trimming.
|
|
mysqld_version_string.scan(/\d+\.\d+\.\d+/).first unless mysqld_version_string.nil?
|
|
end
|
|
|
|
def mysqld_version
|
|
self.class.mysqld_version
|
|
end
|
|
|
|
def defaults_file
|
|
self.class.defaults_file
|
|
end
|
|
|
|
def self.users
|
|
mysql([defaults_file, '-NBe', "SELECT CONCAT(User, '@',Host) AS User FROM mysql.user"].compact).split("\n")
|
|
end
|
|
|
|
# Take root@localhost and munge it to 'root'@'localhost'
|
|
def self.cmd_user(user)
|
|
"'#{user.sub('@', "'@'")}'"
|
|
end
|
|
|
|
# Take root.* and return ON `root`.*
|
|
def self.cmd_table(table)
|
|
table_string = ''
|
|
|
|
# We can't escape *.* so special case this.
|
|
if table == '*.*'
|
|
table_string << '*.*'
|
|
# Special case also for PROCEDURES
|
|
elsif table.start_with?('PROCEDURE ')
|
|
table_string << table.sub(/^PROCEDURE (.*)(\..*)/, 'PROCEDURE `\1`\2')
|
|
else
|
|
table_string << table.sub(/^(.*)(\..*)/, '`\1`\2')
|
|
end
|
|
table_string
|
|
end
|
|
|
|
def self.cmd_privs(privileges)
|
|
if privileges.include?('ALL')
|
|
return 'ALL PRIVILEGES'
|
|
else
|
|
priv_string = ''
|
|
privileges.each do |priv|
|
|
priv_string << "#{priv}, "
|
|
end
|
|
end
|
|
# Remove trailing , from the last element.
|
|
priv_string.sub(/, $/, '')
|
|
end
|
|
|
|
# Take in potential options and build up a query string with them.
|
|
def self.cmd_options(options)
|
|
option_string = ''
|
|
options.each do |opt|
|
|
if opt == 'GRANT'
|
|
option_string << ' WITH GRANT OPTION'
|
|
end
|
|
end
|
|
option_string
|
|
end
|
|
|
|
end
|