Magellan Linux

  • Back to homepage
    • /[alx-svn]/alx-src/branches/alx-web-070/scripts/sql-schema/mcore-sql-schema.sh

    Diff of /alx-src/branches/alx-web-070/scripts/sql-schema/mcore-sql-schema.sh

    Parent Directory Parent Directory | Revision Log Revision Log | View Patch Patch

    revision 8493 by niro, Fri Feb 5 13:18:40 2016 UTC revision 8505 by niro, Fri Feb 5 15:16:07 2016 UTC
    # Line 139  sql_add_column() Line 139  sql_add_column()
    139   local column   local column
    140   local autoincrement   local autoincrement
    141   local primary   local primary
    142     local current_primary
    143     local current_autoincrement
    144     local current_opts
    145    
    146   table="${TABLE_DEFINITION[0]}"   table="${TABLE_DEFINITION[0]}"
    147   count="${#TABLE_DEFINITION[*]}"   count="${#TABLE_DEFINITION[*]}"
    # Line 160  sql_add_column() Line 163  sql_add_column()
    163   *auto_increment*) opts="${opts//auto_increment}"; autoincrement="${column} ${opts}" ;;   *auto_increment*) opts="${opts//auto_increment}"; autoincrement="${column} ${opts}" ;;
    164   esac   esac
    165    
    166   mysqldo "ALTER TABLE ${MCORE_SQL_DB}.${table} ADD ${column} ${opts}) AFTER ${after_column};" || die "add column '${table}'"   mysqldo "ALTER TABLE ${MCORE_SQL_DB}.${table} ADD ${column} ${opts} AFTER ${after_column};" || die "add column '${table}'"
    167   done   done
    168    
    169     # delete an existing auto_increment first
    170     if [[ -n ${autoincrement} ]]
    171     then
    172     i=( $(mysqldo 'SHOW COLUMNS FROM '${MCORE_SQL_DB}.${table}' WHERE `Extra`="auto_increment"') )
    173     current_autoincrement="${i[0]}"
    174     if [[ ${current_autoincrement} != ${column} ]] && [[ -n ${current_autoincrement} ]]
    175     then
    176     current_opts=( "${i[1]}" ) # type eg int(11)
    177     # null or not
    178     case "${i[2]}" in
    179     NO|no) current_opts+=( "NOT NULL" ) ;;
    180     YES|yes) current_opts+=( "DEFAULT ${i[4]}" ) ;; # should never match, but to be save
    181     esac
    182     mysqldo "ALTER TABLE ${MCORE_SQL_DB}.${table} CHANGE ${current_autoincrement} ${current_autoincrement} ${current_opts};" || die "removing auto_increment to table '${table}'"
    183     fi
    184     fi
    185    
    186   if [[ -n ${primary} ]]   if [[ -n ${primary} ]]
    187   then   then
    188     # only run this if the primary key is not already the same column
    189     i=( $(mysqldo 'SHOW COLUMNS FROM '${MCORE_SQL_DB}.${table}' WHERE `Key`="PRI"') )
    190     current_primary="${i[0]}"
    191     if [[ -n ${current_primary} ]]
    192     then
    193     mysqldo "ALTER TABLE ${MCORE_SQL_DB}.${table} DROP PRIMARY KEY;" || die "adding primary key to table '${table}'"
    194     fi
    195   mysqldo "ALTER TABLE ${MCORE_SQL_DB}.${table} ADD PRIMARY KEY (${primary});" || die "adding primary key to table '${table}'"   mysqldo "ALTER TABLE ${MCORE_SQL_DB}.${table} ADD PRIMARY KEY (${primary});" || die "adding primary key to table '${table}'"
    196   fi   fi
    197   if [[ -n ${autoincrement} ]]   if [[ -n ${autoincrement} ]]
    # Line 189  sql_modify_column() Line 216  sql_modify_column()
    216   local column   local column
    217   local autoincrement   local autoincrement
    218   local primary   local primary
    219     local current_primary
    220     local current_autoincrement
    221     local current_opts
    222    
    223   table="${TABLE_DEFINITION[0]}"   table="${TABLE_DEFINITION[0]}"
    224   count="${#TABLE_DEFINITION[*]}"   count="${#TABLE_DEFINITION[*]}"
    # Line 209  sql_modify_column() Line 239  sql_modify_column()
    239   *auto_increment*) opts="${opts//auto_increment}"; autoincrement="${column} ${opts}" ;;   *auto_increment*) opts="${opts//auto_increment}"; autoincrement="${column} ${opts}" ;;
    240   esac   esac
    241    
    242   mysqldo "ALTER TABLE ${MCORE_SQL_DB}.${table} MODIFY ${column} ${opts});" || die "modify table '${table}'"   mysqldo "ALTER TABLE ${MCORE_SQL_DB}.${table} MODIFY ${column} ${opts};" || die "modify table '${table}'"
    243   done   done
    244    
    245     # delete an existing auto_increment first
    246     if [[ -n ${autoincrement} ]]
    247     then
    248     i=( $(mysqldo 'SHOW COLUMNS FROM '${MCORE_SQL_DB}.${table}' WHERE `Extra`="auto_increment"') )
    249     echo "DEBUG: i='${i[*]}'"
    250     current_autoincrement="${i[0]}"
    251     if [[ ${current_autoincrement} != ${column} ]] && [[ -n ${current_autoincrement} ]]
    252     then
    253     current_opts=( "${i[1]}" ) # type eg int(11)
    254     # null or not
    255     case "${i[2]}" in
    256     NO|no) current_opts+=( "NOT NULL" ) ;;
    257     YES|yes) current_opts+=( "DEFAULT ${i[4]}" ) ;; # should never match, but to be save
    258     esac
    259     mysqldo "ALTER TABLE ${MCORE_SQL_DB}.${table} CHANGE ${current_autoincrement} ${current_autoincrement} ${current_opts};" || die "removing auto_increment to table '${table}'"
    260     fi
    261     fi
    262    
    263   if [[ -n ${primary} ]]   if [[ -n ${primary} ]]
    264   then   then
    265     # only run this if the primary key is not already the same column
    266     i=( $(mysqldo 'SHOW COLUMNS FROM '${MCORE_SQL_DB}.${table}' WHERE `Key`="PRI"') )
    267     current_primary="${i[0]}"
    268     if [[ -n ${current_primary} ]]
    269     then
    270     mysqldo "ALTER TABLE ${MCORE_SQL_DB}.${table} DROP PRIMARY KEY;" || die "adding primary key to table '${table}'"
    271     fi
    272   mysqldo "ALTER TABLE ${MCORE_SQL_DB}.${table} ADD PRIMARY KEY (${primary});" || die "adding primary key to table '${table}'"   mysqldo "ALTER TABLE ${MCORE_SQL_DB}.${table} ADD PRIMARY KEY (${primary});" || die "adding primary key to table '${table}'"
    273   fi   fi
    274   if [[ -n ${autoincrement} ]]   if [[ -n ${autoincrement} ]]
    # Line 278  sql_set_value() Line 333  sql_set_value()
    333  create_database()  create_database()
    334  {  {
    335   create_database_schema   create_database_schema
    336    
    337     # update database schema version
    338     mysqldo "INSERT INTO ${MCORE_SQL_DB}.meta_schema(version) VALUES ('${MCORE_SQL_DB_SCHEMA_VERSION}') ON DUPLICATE KEY UPDATE version='${MCORE_SQL_DB_SCHEMA_VERSION}';" || die "updating schema version"
    339  }  }
    340    
    341  update_database()  update_database()
    342  {  {
    343   local current_sql_db_version   local current_sql_db_schema_version
    344   local i   local i
    345    
    346   current_sql_db_version=$(mysqldo "SELECT MAX(version) from meta;")   current_sql_db_schema_version=$(mysqldo "SELECT MAX(version) from meta_schema;")
    347    
    348   if [[ ${current_sql_db_version} = ${MCORE_SQL_DB_VERSION} ]]   if [[ ${current_sql_db_schema_version} = ${MCORE_SQL_DB_SCHEMA_VERSION} ]]
    349   then   then
    350   echo "Database is already up to date"   echo "Database schema is already up to date"
    351   return 0   return 0
    352   fi   fi
    353    
    354   # run every update_to_database_version_X script which exist up to version MCORE_SQL_DB_VERSION   # run every update_to_database_version_X script which exist up to version MCORE_SQL_DB_SCHEMA_VERSION
    355   for i in $(seq $((${current_sql_db_version}+1)) ${MCORE_SQL_DB_VERSION})   for i in $(seq $((${current_sql_db_schema_version}+1)) ${MCORE_SQL_DB_SCHEMA_VERSION})
    356   do   do
    357   if [[ -n $(typeset -f update_to_database_version_${i}) ]]   if [[ -n $(typeset -f update_to_database_schema_version_${i}) ]]
    358   then   then
    359   echo "Running update_to_database_schema_version_${i}()"   echo "Running update_to_database_schema_version_${i}()"
    360   update_to_database_schema_version_${i}   update_to_database_schema_version_${i} || die
    361   fi   fi
    362   done   done
    363    
    364     # update database schema version
    365     mysqldo "INSERT INTO ${MCORE_SQL_DB}.meta_schema(version) VALUES ('${MCORE_SQL_DB_SCHEMA_VERSION}') ON DUPLICATE KEY UPDATE version='${MCORE_SQL_DB_SCHEMA_VERSION}';" || die "updating schema version"
    366  }  }
    367    
    368  fill_database()  fill_database()
    369  {  {
    370     local current_sql_db_values_version
    371     local i
    372    
    373     current_sql_db_values_version=$(mysqldo "SELECT MAX(version) from meta_values;")
    374    
    375     if [[ ${current_sql_db_values_version} = ${MCORE_SQL_DB_VALUES_VERSION} ]]
    376     then
    377     echo "Database values are already up to date"
    378     return 0
    379     fi
    380    
    381   create_database_values   create_database_values
    382     # update database values version
    383     mysqldo "INSERT INTO ${MCORE_SQL_DB}.meta_values(version) VALUES ('${MCORE_SQL_DB_VALUES_VERSION}') ON DUPLICATE KEY UPDATE version='${MCORE_SQL_DB_VALUES_VERSION}';" || die "updating values version"
    384  }  }
    385    
    386  case $1 in  case $1 in
    Legend:
    Removed from v.8493  
    changed lines
      Added in v.8505