Persistence-Entity

 view release on metacpan or  search on metacpan

t/relationship/to_one_relationship.t  view on Meta::CPAN


    my $dept_entity = Persistence::Entity->new(
        name    => 'dept',
        alias   => 'dt',
        primary_key => ['deptno'],
        columns => [
            sql_column(name => 'deptno'),
            sql_column(name => 'dname'),
            sql_column(name => 'loc'),
            sql_column(name => 'addr_id'),
        ],
    );
    
    
    my $address_entity = Persistence::Entity->new(
        name    => 'address',
        alias   => 'ar',
        primary_key => ['id'],
        columns => [
            sql_column(name => 'id'),
            sql_column(name => 'loc'),
            sql_column(name => 'town'),
            sql_column(name => 'postcode'),
        ],
    );
    
    $dept_entity->add_to_many_relationships(sql_relationship(target_entity => $emp_entity, join_columns => ['deptno'], order_by => 'deptno, empno'));
    $dept_entity->add_to_one_relationships(sql_relationship(target_entity => $address_entity, join_columns => ['addr_id']));
    
    $entity_manager->add_entities($dept_entity, $emp_entity, $address_entity);
}

{
    package Address;
    
    use Abstract::Meta::Class ':all';
    use Persistence::ORM ':all';

    entity 'address';
    column id  => has('$.id');
    column loc  => has('$.location');
    column town => has('$.town');
    column postcode  => has('$.postcode');
    
    
}


{
    package Department;
    
    use Abstract::Meta::Class ':all';
    use Persistence::ORM ':all';

    entity 'dept';
    column deptno   => has('$.id');
    column dname    => has('$.name');
    column loc      => has('$.location');   
    to_one 'address' => (
        attribute        =>  has ('$.address', associated_class => 'Address'),
        cascade          => ALL,
        fetch_method     => LAZY,
    );
}


{
    package Employee;
    
    use Abstract::Meta::Class ':all';
    use Persistence::Entity ':all';
    use Persistence::ORM ':all';
    
    entity 'emp';
    column empno=> has('$.id');
    column ename => has('$.name');
    column job => has '$.job';
    my $relation = to_one 'dept' => (
        attribute        =>  has ('$.dept', associated_class => 'Department'),
        cascade          => ALL,
        fetch_method     => EAGER,
    );

    ::is_deeply([$class->insertable_to_one_relations('Employee')], [$relation], 'should have insertable relations');
    ::is_deeply([$class->updatable_to_one_relations('Employee')],  [$relation],  'should have updatable relations');
    ::is_deeply([$class->deleteable_to_one_relations('Employee')], [$relation], 'should have deleteable relations');

}

SKIP: {
    
    ::skip('missing env varaibles DB_TEST_CONNECTION, DB_TEST_USERNAME DB_TEST_PASSWORD', 16)
      unless $ENV{DB_TEST_CONNECTION};

    my $connection = DBIx::Connection->new(
      name     => 'test',
      dsn      => $ENV{DB_TEST_CONNECTION},
      username => $ENV{DB_TEST_USERNAME},
      password => $ENV{DB_TEST_PASSWORD},
    ); 


    reset_schema_ok("t/sql/". $connection->dbms_name . "/create_schema.sql");

    {
        xml_dataset_ok('init');
        
        my $dept = Department->new(
            id      => 30,
            name    => 'HO',
            address => Address->new(
                id       => 1,
                town     => 'Lodnon',
                postcode => 'N11 2SA',
                location => 'Warwick Rd'
            )
        );
        $entity_manager->insert($dept);
        
        expected_xml_dataset_ok('insert_1');
    }

    {
        my ($dept) = $entity_manager->find(dept => 'Department', name => 'HO');
        is_deeply($dept->address,
            Address->new(
                id       => 1,
                town     => 'Lodnon',
                postcode => 'N11 2SA',
                location => 'Warwick Rd'
            ), 'should have dept association');
        
        $dept->set_name('HO - 1');
        $dept->set_address(
                Address->new(
                id       => 2,
                town     => 'Lodnon',
                postcode => 'W11 2A',
                location => 'Kong Rd'
            )
        );
        $entity_manager->update($dept);
        expected_xml_dataset_ok('update_1');
    }

    {
        my ($dept) = $entity_manager->find(dept => 'Department', name => 'HO - 1');
        $entity_manager->delete($dept);
        expected_xml_dataset_ok('delete_1');
        
    }
    
    xml_dataset_ok('init');

    {   #fetch
        my ($emp) = $entity_manager->find(emp => 'Employee', name => 'emp2');
        my $dept = Department->new(id => 5, name => 'dept5', location   => 'loc5');
        is_deeply($emp->{'$.dept'}, $dept, 'should fetch eagerly association data')
    }
    
    #cascade on insert
    {
        
        my $emp = Employee->new(id => 21, name => 'emp21', job => undef);
        my $dept = Department->new(id => '50', name => 'dept50', location => 'loc50');
        $emp->set_dept($dept);
        $entity_manager->insert($emp);
    }
    
    expected_xml_dataset_ok('insert');


    #cascade on update 
    {
        my ($emp) = $entity_manager->find(emp => 'Employee', name => 'emp2');
        $emp->dept->set_location('Warsaw');
        $emp->set_job('Manager');
        $entity_manager->update($emp);
    }
    expected_xml_dataset_ok('update');

    xml_dataset_ok('update');
    {
        my ($emp) = $entity_manager->find(emp => 'Employee', name => 'emp2');
        my $dept = Department->new(id => '5', name => 'dept5', location => 'Warsaw');
        $emp->set_dept($dept);
        $entity_manager->update($emp);
    }
    expected_xml_dataset_ok('update');

    xml_dataset_ok('update');
    {
        my ($emp) = $entity_manager->find(emp => 'Employee', name => 'emp2');
        $emp->set_dept(undef);
        $entity_manager->update($emp);
    }
    expected_xml_dataset_ok('update2');
    
    xml_dataset_ok('init');
    
    #cascade on delete
    {
        my ($emp) = $entity_manager->find(emp => 'Employee', name => 'emp2');
        $entity_manager->delete($emp);
    }
    expected_xml_dataset_ok('delete');
    
}



( run in 0.499 second using v1.01-cache-2.11-cpan-5c0b1e786e0 )