1a2
> // $ID$
4,24c5,7
<   switch ($GLOBALS['db_type']) {
<     case 'mysql':
<     case 'mysqli':
<       db_query('CREATE TABLE {job_queue} (
<         jqid int NOT NULL,
<         created int NOT NULL,
<         description varchar(255) NOT NULL,
<         function varchar(255) NOT NULL,
<         arguments text NOT NULL,
<         file varchar(255) NOT NULL,
<         priority tinyint NOT NULL,
<         PRIMARY KEY (jqid),
<         INDEX (priority, jqid)
<       ) /*!40100 DEFAULT CHARACTER SET UTF8 */ ');
<       db_query('CREATE TABLE {job_queue_functions} (
<         function varchar(255) NOT NULL,
<         priority tinyint NOT NULL,
<         PRIMARY KEY (function)
<       ) /*!40100 DEFAULT CHARACTER SET UTF8 */ ');
<       break;
<   }
---
>   // Create tables.
>   drupal_install_schema('job_queue');
>   drupal_install_schema('job_queue_functions');
27,35d9
< function job_queue_update_1() {
<   $return = array();
< 
<   switch ($GLOBALS['db_type']) {
<     case 'mysql':
<     case 'mysqli':
<       $return[] = update_sql('ALTER TABLE {job_queue} ADD file varchar(255) NOT NULL');
<       break;
<   }
37c11,17
<   return $return;
---
> /**
> * Implementation of hook_uninstall().
> */
> function job_queue_uninstall() {
>   // Remove tables.
>   drupal_uninstall_schema('job_queue');
>   drupal_uninstall_schema('job_queue_functions');
40,41d19
< function job_queue_update_2() {
<   $return = array();
43,54c21,50
<   switch ($GLOBALS['db_type']) {
<     case 'mysql':
<     case 'mysqli':
<       $return[] = update_sql('CREATE TABLE {job_queue_functions} (
<         function varchar(255) NOT NULL,
<         priority tinyint NOT NULL,
<         PRIMARY KEY (function)
<       ) /*!40100 DEFAULT CHARACTER SET UTF8 */ ');
<       $return[] = update_sql('ALTER TABLE {job_queue} ADD priority tinyint NOT NULL');
<       $return[] = update_sql('ALTER TABLE {job_queue} ADD INDEX (priority, jqid)');
<       break;
<   }
---
> /**
> * Implementation of hook_schema().
> */
> function job_queue_schema() {
>   $schema['job_queue'] = array(
>     'fields' => array(
>       'jqid'        => array('type' => 'serial', 'not null' => TRUE),
>       'created'      => array('type' => 'int', 'not null' => TRUE, 'default' => 0),
>       'description'  => array('type' => 'varchar', 'length' => 255, 'not null' => TRUE),
>       'function'     => array('type' => 'varchar', 'length' => 255, 'not null' => TRUE),
>       'arguments'    => array('type' => 'text', 'not null' => TRUE),
>       'file'         => array('type' => 'varchar', 'length' => 255, 'not null' => TRUE),
>       'priority'     => array('type' => 'int',  'not null' => TRUE, 'size' => 'tiny'),
>     ),
>     'indexes' => array(
>       'priority'  => array('priority'),
>       'jqid'      => array('jqid'),
>     ),
>     'primary key' => array('jqid'),
>   );
>   $schema['job_queue_functions'] = array(
>     'fields' => array(
>       'function'  => array('type' => 'varchar', 'length' => 255, 'not null' => TRUE),
>       'priority'     => array('type' => 'int',  'not null' => TRUE, 'size' => 'tiny'),
>     ),
>     'primary key' => array('function'),
>   );
>   return $schema;
> }
> 
56c52,55
<   return $return;
---
> function job_queue_update_1() {
>   $ret = array();
>   db_add_field($ret, 'job_queue', 'file', array('type' => 'varchar', 'not null' => TRUE, 'length' => 255));
>   return $ret;
57a57,75
> 
> 
> function job_queue_update_2() {
>   $ret = array();
>   //db_add_field($ret, 'job_queue', 'file', array('type' => 'varchar', 'not null' => TRUE, 'length' => 255));
> 
>   $schema['job_queue_functions'] = array(
>     'fields' => array(
>       'function'  => array('type' => 'varchar', 'length' => 255, 'not null' => TRUE),
>       'priority'     => array('type' => 'int',  'not null' => TRUE, 'size' => 'tiny'),
>     ),
>     'primary key' => array('function'),
>   );
>   db_create_table($ret, 'job_queue_functions', $schema['job_queue_functions']);
>   db_add_field($ret, 'job_queue', 'priority', array('type' => 'int', 'not null' => TRUE, 'size' => 'tiny'));
>   db_add_index($ret, 'job_queue', 'priority', array('priority'));
>   db_add_index($ret, 'job_queue', 'jqid', array('jqid'));
>   return $ret;
> }
\ No newline at end of file