diff options
author | ivan <ivan> | 2007-10-25 19:03:53 +0000 |
---|---|---|
committer | ivan <ivan> | 2007-10-25 19:03:53 +0000 |
commit | cb008af3d5847be4e31f5f67e3ac017b8adea58f (patch) | |
tree | 1412788a8715d57346ce029ecd10158721168581 /FS/FS | |
parent | ebf5ce9df0ea2026ab44f5dd80341dd06c68970d (diff) |
mysql, yes, mysql.
Diffstat (limited to 'FS/FS')
-rw-r--r-- | FS/FS/Schema.pm | 15 | ||||
-rw-r--r-- | FS/FS/TicketSystem/RT_External.pm | 30 |
2 files changed, 23 insertions, 22 deletions
diff --git a/FS/FS/Schema.pm b/FS/FS/Schema.pm index a5954e949..d1be9f1f0 100644 --- a/FS/FS/Schema.pm +++ b/FS/FS/Schema.pm @@ -229,7 +229,7 @@ sub dbdef_dist { qw( name type null length default local ) } ); - if ( $column->type eq 'serial' ) { + if ( $column->type =~ /^(\w*)SERIAL$/i ) { $column->type('int'); $column->null('NULL'); } @@ -1022,7 +1022,7 @@ sub tables_hashref { 'catchall', 'int', 'NULL', '', '', '', 'parent_svcnum', 'int', 'NULL', '', '', '', 'registrarnum', 'int', 'NULL', '', '', '', - 'registrarkey', 'varchar', 'NULL', '', '', '', + 'registrarkey', 'varchar', 'NULL', 512, '', '', 'setup_date', @date_type, '', '', 'renewal_interval', 'int', 'NULL', '', '', '', 'expiration_date', @date_type, '', '', @@ -1576,7 +1576,8 @@ sub tables_hashref { ### 'acctid', 'bigserial', '', '', '', '', - 'calldate', 'TIMESTAMP with time zone', '', '', \'now()', '', + #'calldate', 'TIMESTAMP with time zone', '', '', \'now()', '', + 'calldate', 'timestamp', '', '', \'now()', '', 'clid', 'varchar', '', $char_d, \"''", '', 'src', 'varchar', '', $char_d, \"''", '', 'dst', 'varchar', '', $char_d, \"''", '', @@ -1668,7 +1669,7 @@ sub tables_hashref { 'cdr_type' => { 'columns' => [ 'cdrtypenum' => 'serial', '', '', '', '', - 'cdrtypename' => 'varchar', '', '', '', '', + 'cdrtypename' => 'varchar', '', $char_d, '', '', ], 'primary_key' => 'cdrtypenum', 'unique' => [], @@ -1678,7 +1679,7 @@ sub tables_hashref { 'cdr_carrier' => { 'columns' => [ 'carrierid' => 'serial', '', '', '', '', - 'carriername' => 'varchar', '', '', '', '', + 'carriername' => 'varchar', '', $char_d, '', '', ], 'primary_key' => 'carrierid', 'unique' => [], @@ -1783,7 +1784,7 @@ sub tables_hashref { 'rightnum', 'serial', '', '', '', '', 'righttype', 'varchar', '', $char_d, '', '', 'rightobjnum', 'int', '', '', '', '', - 'rightname', 'varchar', '', '', '', '', + 'rightname', 'varchar', '', $char_d, '', '', ], 'primary_key' => 'rightnum', 'unique' => [ [ 'righttype', 'rightobjnum', 'rightname' ] ], @@ -1830,7 +1831,7 @@ sub tables_hashref { 'confnum', 'serial', '', '', '', '', 'agentnum', 'int', 'NULL', '', '', '', 'name', 'varchar', '', $char_d, '', '', - 'value', 'varchar', 'NULL', '', '', '', # Pg specific + 'value', 'long varbinary', 'NULL', '', '', '', ], 'primary_key' => 'confnum', 'unique' => [ [ 'agentnum', 'name' ]], diff --git a/FS/FS/TicketSystem/RT_External.pm b/FS/FS/TicketSystem/RT_External.pm index 0b9a98e0e..be5f22a77 100644 --- a/FS/FS/TicketSystem/RT_External.pm +++ b/FS/FS/TicketSystem/RT_External.pm @@ -73,8 +73,8 @@ sub customer_tickets { $limit ||= 0; my( $from_sql, @param) = $self->_from_customer( $custnum, $priority ); - my $sql="SELECT tickets.*, queues.name, ". - "position(tickets.status in 'newopenstalledresolvedrejecteddeleted')". + my $sql="SELECT Tickets.*, Queues.name, ". + "position(Tickets.status in 'newopenstalledresolvedrejecteddeleted')". " AS svalue " . ( length($priority) ? ", objectcustomfieldvalues.content" : '' ). " $from_sql ". @@ -100,8 +100,8 @@ sub _from_customer { my $where = ''; if ( defined($priority) ) { - my $queue_sql = " ObjectCustomFields.ObjectId = ( SELECT id FROM queues - WHERE queues.name = ? ) + my $queue_sql = " ObjectCustomFields.ObjectId = ( SELECT id FROM Queues + WHERE Queues.name = ? ) OR ( ? = '' AND ObjectCustomFields.ObjectId = 0 )"; my $customfield_sql = @@ -131,7 +131,7 @@ sub _from_customer { unshift @param, $priority; $join = "JOIN ObjectCustomFieldValues - ON ( tickets.id = ObjectCustomFieldValues.ObjectId )"; + ON ( Tickets.id = ObjectCustomFieldValues.ObjectId )"; $where = " AND content = ? AND ObjectCustomFieldValues.disabled != 1 @@ -142,7 +142,7 @@ sub _from_customer { $where = "AND 0 = ( SELECT count(*) FROM ObjectCustomFieldValues - WHERE ObjectId = tickets.id + WHERE ObjectId = Tickets.id AND ObjectType = 'RT::Ticket' AND $customfield_sql ) @@ -152,9 +152,9 @@ sub _from_customer { } my $sql = " - FROM tickets - JOIN queues ON ( tickets.queue = queues.id ) - JOIN links ON ( tickets.id = links.localbase ) + FROM Tickets + JOIN Queues ON ( Tickets.queue = Queues.id ) + JOIN Links ON ( Tickets.id = Links.localbase ) $join WHERE ( ". join(' OR ', map "status = '$_'", $self->statuses ). " ) AND target = 'freeside://freeside/cust_main/$custnum' @@ -259,7 +259,7 @@ sub href_ticket { sub queues { my($self) = @_; - my $sql = "SELECT id, name FROM queues WHERE disabled = 0"; + my $sql = "SELECT id, name FROM Queues WHERE disabled = 0"; my $sth = $dbh->prepare($sql) or die $dbh->errstr. " preparing $sql"; $sth->execute() or die $sth->errstr. " executing $sql"; @@ -272,7 +272,7 @@ sub queue { return '' unless $queueid; - my $sql = "SELECT name FROM queues WHERE id = ?"; + my $sql = "SELECT name FROM Queues WHERE id = ?"; my $sth = $dbh->prepare($sql) or die $dbh->errstr. " preparing $sql"; $sth->execute($queueid) or die $sth->errstr. " executing $sql"; @@ -319,8 +319,8 @@ sub transaction_ticketid { sub transaction_subject { my( $self, $transaction_id ) = @_; - my $sql = "SELECT subject from transactions JOIN tickets ON objectid=". - "tickets.id WHERE transactions.id = ". $transaction_id; + my $sql = "SELECT subject from Transactions JOIN Tickets ON objectid=". + "Tickets.id WHERE transactions.id = ". $transaction_id; $self->_retrieve_single_value($sql); } @@ -328,8 +328,8 @@ sub transaction_subject { sub transaction_status { my( $self, $transaction_id ) = @_; - my $sql = "SELECT status from transactions JOIN tickets ON objectid=". - "tickets.id WHERE transactions.id = ". $transaction_id; + my $sql = "SELECT status from Transactions JOIN Tickets ON objectid=". + "Tickets.id WHERE transactions.id = ". $transaction_id; $self->_retrieve_single_value($sql); } |