Subversion Repositories DevTools

###############################################################################

# Codestriker: Copyright (c) 2001, 2002 David Sitsky.  All rights reserved.

# sits@users.sourceforge.net

#

# This program is free software; you can redistribute it and modify it under

# the terms of the GPL.

# Model object for handling topic file data.

package Codestriker::Model::File;

use strict;

use Codestriker::Model::Delta;

# Create the appropriate delta rows for this review.  Note this gets called

# from Topic::create(), which controls the transaction commit/rollback.

sub create($$$$) {

    my ($type, $dbh, $topicid, $deltas_ref) = @_;

    # Create the appropriate prepared statements.

    my $insert_file =

	$dbh->prepare_cached('INSERT INTO topicfile ' .

			     '(topicid, sequence, filename,' .

			     ' topicoffset, revision, diff, binaryfile) ' .

			     'VALUES (?, ?, ?, ?, ?, ?, ?)');

    my $success = defined $insert_file;

    my $insert_delta =

	$dbh->prepare_cached('INSERT INTO delta (topicid, file_sequence, ' .

			     'delta_sequence, old_linenumber, ' .

			     'new_linenumber, deltatext, ' .

			     'description, repmatch) ' .

			     'VALUES (?, ?, ?, ?, ?, ?, ?, ?)');

    $success &&= defined $insert_delta;

    my @deltas = @$deltas_ref;

    my $last_filename = "";

    my $file_sequence = -1;

    my $delta_sequence = -1;

    for (my $i = 0; $i <= $#deltas; $i++) {

	my $delta = $deltas[$i];

	if ($last_filename ne $delta->{filename}) {

	    # Create new file entry.

	    $success &&= $insert_file->execute($topicid,

					       ++$file_sequence,

					       $delta->{filename}, -1,

					       $delta->{revision}, "",

					       $delta->{binary});

	    $last_filename = $delta->{filename};

	}

	# Add the new delta entry.

	$success &&= $insert_delta->execute($topicid, $file_sequence,

					    ++$delta_sequence,

					    $delta->{old_linenumber},

					    $delta->{new_linenumber},

					    $delta->{text},

					    $delta->{description},

					    $delta->{repmatch});

    }

    die $dbh->errstr unless $success;

}

# Retrieve the details of a file for a specific topicid and filenumber.

sub get($$$$$$) {

    my ($type, $topicid, $filenumber,

	$offset_ref, $revision_ref, $diff_ref) = @_;

    # Obtain a database connection.

    my $dbh = Codestriker::DB::DBI->get_connection();

    # Retrieve the file information.

    my $select_file =

	$dbh->prepare_cached('SELECT topicoffset, revision, diff ' .

			     'FROM topicfile ' .

			     'WHERE topicid = ? AND sequence = ?');

    my $success = defined $select_file;

    $success &&= $select_file->execute($topicid, $filenumber);

    if ($success) {

	my ($offset, $revision, $diff) = $select_file->fetchrow_array();

	# Store the results in the reference variables and return.

	$$offset_ref = $offset;

	$$revision_ref = $revision;

	$$diff_ref = $diff;

	$select_file->finish();

    }

    Codestriker::DB::DBI->release_connection($dbh, $success);

    die $dbh->errstr unless $success;

}

# Retrieve the details of which files, revisions and offsets are present for

# a specific topic.

sub get_filetable($$$$$$$) {

    my ($type, $topicid, $filename_array_ref, $revision_array_ref,

	$offset_array_ref, $binary_array_ref, $numchanges_array_ref) = @_;

    # Obtain a database connection.

    my $dbh = Codestriker::DB::DBI->get_connection();

    # Setup the appropriate statement and execute it.

    my $select_file =

	$dbh->prepare_cached('SELECT filename, revision, topicoffset, ' .

			     'binaryfile, sequence FROM topicfile ' .

			     'WHERE topicid = ? ' .

			     'ORDER BY sequence');

    my $success = defined $select_file;

    $success &&= $select_file->execute($topicid);

    # Store the results in the referenced arrays.

    if ($success) {

	my @data;

        my @sequence;

	while (@data = $select_file->fetchrow_array()) {

	    push @$filename_array_ref, $data[0];

	    push @$revision_array_ref, $data[1];

	    push @$offset_array_ref, $data[2];

	    push @$binary_array_ref, $data[3];

	    push @sequence, $data[4];

	}

	$select_file->finish();

	# This has to be called outside the loop above, as SQL Server

	# doesn't allow nested selects... gggrrrr.

	foreach my $file_id (@sequence) {

	    # Now get the number of lines affected in this file

	    my $numchanges = Codestriker::Model::Delta->get_delta_size($topicid, $file_id);

	    push @$numchanges_array_ref, $numchanges;

	}

    }

    Codestriker::DB::DBI->release_connection($dbh, $success);

    die $dbh->errstr unless $success;

}

1;