DataSourceLevelDbImpl.java

/*
 * Copyright (c) 2015 Maxim Yunusov
 *    Licensed under the Apache License, Version 2.0 (the "License");
 *    you may not use this file except in compliance with the License.
 *    You may obtain a copy of the License at
 *
 *        http://www.apache.org/licenses/LICENSE-2.0
 *
 *    Unless required by applicable law or agreed to in writing, software
 *    distributed under the License is distributed on an "AS IS" BASIS,
 *    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 *    See the License for the specific language governing permissions and
 *    limitations under the License.
 */

package org.maxur.perfmodel.backend.infrastructure;

import org.iq80.leveldb.DB;
import org.iq80.leveldb.DBIterator;
import org.iq80.leveldb.Options;
import org.iq80.leveldb.WriteBatch;
import org.iq80.leveldb.impl.Iq80DBFactory;
import org.maxur.perfmodel.backend.service.Benchmark;
import org.maxur.perfmodel.backend.service.DataSource;
import org.maxur.perfmodel.backend.service.Database;
import org.slf4j.Logger;

import javax.annotation.PostConstruct;
import javax.annotation.PreDestroy;
import javax.inject.Named;
import java.io.*;
import java.util.Collection;
import java.util.HashSet;
import java.util.Optional;

import static org.iq80.leveldb.impl.Iq80DBFactory.asString;
import static org.iq80.leveldb.impl.Iq80DBFactory.bytes;
import static org.slf4j.LoggerFactory.getLogger;

public class DataSourceLevelDbImpl implements DataSource, Database {

    private static final Logger LOGGER = getLogger(DataSourceLevelDbImpl.class);

    private DB db;

    @SuppressWarnings("unused")
    @Named("db.folderName")
    private String dbFolderName;

    @Override
    @PostConstruct
    public void init() {
        if (db != null) {
            return;
        }
        final Options options = new Options();
        options.createIfMissing(true);
        try {
            final Iq80DBFactory factory = Iq80DBFactory.factory;
            db = factory.open(new File(dbFolderName), options);
            LOGGER.info("LevelDb Database ({}) is opened", factory.toString());
        } catch (IOException e) {
            final String msg = "LevelDb Database is not opened";
            LOGGER.error(msg, e);
            throw new IllegalStateException(msg, e);
        }
    }

    @Override
    @PreDestroy
    public void stop() {
        try {
            db.close();
            LOGGER.info("LevelDb Database is closed now");
        } catch (IOException e) {
            LOGGER.error("LevelDb Database is not closed", e);
        }
    }

    @Override
    @Benchmark
    public <T> Optional<T> get(final String key) throws IOException, ClassNotFoundException {
        return Optional.<T>ofNullable(objectFrom(db.get(bytes(key))));
    }

    @Override
    @Benchmark
    public <T> Collection<T> findAllByPrefix(final String prefix) throws IOException, ClassNotFoundException {
        final Collection<T> values = new HashSet<>();
        try (DBIterator iterator = db.iterator()) {
            for (iterator.seek(bytes(prefix)); iterator.hasNext(); iterator.next()) {
                final String key = asString(iterator.peekNext().getKey());
                if (!key.startsWith(prefix)) {
                    break;
                }
                final byte[] value = iterator.peekNext().getValue();
                values.add(objectFrom(value));
            }
        }
        return values;
    }

    @Override
    @Benchmark
    public void delete(String key) {
        db.delete(bytes(key));
    }

    @Override
    @Benchmark
    public WriteBatch createWriteBatch() {
        return db.createWriteBatch();
    }

    @Override
    @Benchmark
    public void commit(WriteBatch batch) {
        db.write(batch);
    }

    @Override
    @Benchmark
    public void put(final String key, final Serializable value) throws IOException {
        db.put(bytes(key), bytesFrom(value));
    }

    private static <T> T objectFrom(final byte[] bytes) throws IOException, ClassNotFoundException {
        if (bytes == null) {
            return null;
        }
        try (ByteArrayInputStream bis = new ByteArrayInputStream(bytes); ObjectInput in = new ObjectInputStream(bis)) {
            //noinspection unchecked
            return (T) in.readObject();
        }
    }


    public static byte[] bytesFrom(final Serializable object) throws IOException {
        if (object == null) {
            return null;
        }
        try (
                ByteArrayOutputStream bos = new ByteArrayOutputStream();
                ObjectOutput out = new ObjectOutputStream(bos)
        ) {
            out.writeObject(object);
            return bos.toByteArray();
        }
    }

}

















Active mutators

INCREMENTS_MUTATOR
VOID_METHOD_CALL_MUTATOR
RETURN_VALS_MUTATOR
MATH_MUTATOR
NEGATE_CONDITIONALS_MUTATOR
INVERT_NEGS_MUTATOR
CONDITIONALS_BOUNDARY_MUTATOR

Tests examined

Report generated by PIT 1.1.6

1		/*
2		* Copyright (c) 2015 Maxim Yunusov
3		* Licensed under the Apache License, Version 2.0 (the "License");
4		* you may not use this file except in compliance with the License.
5		* You may obtain a copy of the License at
6		*
7		* http://www.apache.org/licenses/LICENSE-2.0
8		*
9		* Unless required by applicable law or agreed to in writing, software
10		* distributed under the License is distributed on an "AS IS" BASIS,
11		* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12		* See the License for the specific language governing permissions and
13		* limitations under the License.
14		*/
15
16		package org.maxur.perfmodel.backend.infrastructure;
17
18		import org.iq80.leveldb.DB;
19		import org.iq80.leveldb.DBIterator;
20		import org.iq80.leveldb.Options;
21		import org.iq80.leveldb.WriteBatch;
22		import org.iq80.leveldb.impl.Iq80DBFactory;
23		import org.maxur.perfmodel.backend.service.Benchmark;
24		import org.maxur.perfmodel.backend.service.DataSource;
25		import org.maxur.perfmodel.backend.service.Database;
26		import org.slf4j.Logger;
27
28		import javax.annotation.PostConstruct;
29		import javax.annotation.PreDestroy;
30		import javax.inject.Named;
31		import java.io.*;
32		import java.util.Collection;
33		import java.util.HashSet;
34		import java.util.Optional;
35
36		import static org.iq80.leveldb.impl.Iq80DBFactory.asString;
37		import static org.iq80.leveldb.impl.Iq80DBFactory.bytes;
38		import static org.slf4j.LoggerFactory.getLogger;
39
40		public class DataSourceLevelDbImpl implements DataSource, Database {
41
42		private static final Logger LOGGER = getLogger(DataSourceLevelDbImpl.class);
43
44		private DB db;
45
46		@SuppressWarnings("unused")
47		@Named("db.folderName")
48		private String dbFolderName;
49
50		@Override
51		@PostConstruct
52		public void init() {
53	1 1. init : negated conditional → NO_COVERAGE	if (db != null) {
54		return;
55		}
56		final Options options = new Options();
57		options.createIfMissing(true);
58		try {
59		final Iq80DBFactory factory = Iq80DBFactory.factory;
60		db = factory.open(new File(dbFolderName), options);
61		LOGGER.info("LevelDb Database ({}) is opened", factory.toString());
62		} catch (IOException e) {
63		final String msg = "LevelDb Database is not opened";
64		LOGGER.error(msg, e);
65		throw new IllegalStateException(msg, e);
66		}
67		}
68
69		@Override
70		@PreDestroy
71		public void stop() {
72		try {
73	1 1. stop : removed call to org/iq80/leveldb/DB::close → NO_COVERAGE	db.close();
74		LOGGER.info("LevelDb Database is closed now");
75		} catch (IOException e) {
76		LOGGER.error("LevelDb Database is not closed", e);
77		}
78		}
79
80		@Override
81		@Benchmark
82		public <T> Optional<T> get(final String key) throws IOException, ClassNotFoundException {
83	1 1. get : mutated return of Object value for org/maxur/perfmodel/backend/infrastructure/DataSourceLevelDbImpl::get to ( if (x != null) null else throw new RuntimeException ) → NO_COVERAGE	return Optional.<T>ofNullable(objectFrom(db.get(bytes(key))));
84		}
85
86		@Override
87		@Benchmark
88		public <T> Collection<T> findAllByPrefix(final String prefix) throws IOException, ClassNotFoundException {
89		final Collection<T> values = new HashSet<>();
90		try (DBIterator iterator = db.iterator()) {
91	2 1. findAllByPrefix : negated conditional → NO_COVERAGE 2. findAllByPrefix : removed call to org/iq80/leveldb/DBIterator::seek → NO_COVERAGE	for (iterator.seek(bytes(prefix)); iterator.hasNext(); iterator.next()) {
92		final String key = asString(iterator.peekNext().getKey());
93	1 1. findAllByPrefix : negated conditional → NO_COVERAGE	if (!key.startsWith(prefix)) {
94		break;
95		}
96		final byte[] value = iterator.peekNext().getValue();
97		values.add(objectFrom(value));
98		}
99		}
100	1 1. findAllByPrefix : mutated return of Object value for org/maxur/perfmodel/backend/infrastructure/DataSourceLevelDbImpl::findAllByPrefix to ( if (x != null) null else throw new RuntimeException ) → NO_COVERAGE	return values;
101		}
102
103		@Override
104		@Benchmark
105		public void delete(String key) {
106	1 1. delete : removed call to org/iq80/leveldb/DB::delete → NO_COVERAGE	db.delete(bytes(key));
107		}
108
109		@Override
110		@Benchmark
111		public WriteBatch createWriteBatch() {
112	1 1. createWriteBatch : mutated return of Object value for org/maxur/perfmodel/backend/infrastructure/DataSourceLevelDbImpl::createWriteBatch to ( if (x != null) null else throw new RuntimeException ) → NO_COVERAGE	return db.createWriteBatch();
113		}
114
115		@Override
116		@Benchmark
117		public void commit(WriteBatch batch) {
118	1 1. commit : removed call to org/iq80/leveldb/DB::write → NO_COVERAGE	db.write(batch);
119		}
120
121		@Override
122		@Benchmark
123		public void put(final String key, final Serializable value) throws IOException {
124	1 1. put : removed call to org/iq80/leveldb/DB::put → NO_COVERAGE	db.put(bytes(key), bytesFrom(value));
125		}
126
127		private static <T> T objectFrom(final byte[] bytes) throws IOException, ClassNotFoundException {
128	1 1. objectFrom : negated conditional → NO_COVERAGE	if (bytes == null) {
129	1 1. objectFrom : mutated return of Object value for org/maxur/perfmodel/backend/infrastructure/DataSourceLevelDbImpl::objectFrom to ( if (x != null) null else throw new RuntimeException ) → NO_COVERAGE	return null;
130		}
131		try (ByteArrayInputStream bis = new ByteArrayInputStream(bytes); ObjectInput in = new ObjectInputStream(bis)) {
132		//noinspection unchecked
133		return (T) in.readObject();
134		}
135		}
136
137
138		public static byte[] bytesFrom(final Serializable object) throws IOException {
139	1 1. bytesFrom : negated conditional → NO_COVERAGE	if (object == null) {
140	1 1. bytesFrom : mutated return of Object value for org/maxur/perfmodel/backend/infrastructure/DataSourceLevelDbImpl::bytesFrom to ( if (x != null) null else throw new RuntimeException ) → NO_COVERAGE	return null;
141		}
142		try (
143		ByteArrayOutputStream bos = new ByteArrayOutputStream();
144		ObjectOutput out = new ObjectOutputStream(bos)
145		) {
146	1 1. bytesFrom : removed call to java/io/ObjectOutput::writeObject → NO_COVERAGE	out.writeObject(object);
147		return bos.toByteArray();
148		}
149		}
150
151		}
		Mutations
53		1.1 Location : init Killed by : none negated conditional → NO_COVERAGE
73		1.1 Location : stop Killed by : none removed call to org/iq80/leveldb/DB::close → NO_COVERAGE
83		1.1 Location : get Killed by : none mutated return of Object value for org/maxur/perfmodel/backend/infrastructure/DataSourceLevelDbImpl::get to ( if (x != null) null else throw new RuntimeException ) → NO_COVERAGE
91		1.1 Location : findAllByPrefix Killed by : none negated conditional → NO_COVERAGE 2.2 Location : findAllByPrefix Killed by : none removed call to org/iq80/leveldb/DBIterator::seek → NO_COVERAGE
93		1.1 Location : findAllByPrefix Killed by : none negated conditional → NO_COVERAGE
100		1.1 Location : findAllByPrefix Killed by : none mutated return of Object value for org/maxur/perfmodel/backend/infrastructure/DataSourceLevelDbImpl::findAllByPrefix to ( if (x != null) null else throw new RuntimeException ) → NO_COVERAGE
106		1.1 Location : delete Killed by : none removed call to org/iq80/leveldb/DB::delete → NO_COVERAGE
112		1.1 Location : createWriteBatch Killed by : none mutated return of Object value for org/maxur/perfmodel/backend/infrastructure/DataSourceLevelDbImpl::createWriteBatch to ( if (x != null) null else throw new RuntimeException ) → NO_COVERAGE
118		1.1 Location : commit Killed by : none removed call to org/iq80/leveldb/DB::write → NO_COVERAGE
124		1.1 Location : put Killed by : none removed call to org/iq80/leveldb/DB::put → NO_COVERAGE
128		1.1 Location : objectFrom Killed by : none negated conditional → NO_COVERAGE
129		1.1 Location : objectFrom Killed by : none mutated return of Object value for org/maxur/perfmodel/backend/infrastructure/DataSourceLevelDbImpl::objectFrom to ( if (x != null) null else throw new RuntimeException ) → NO_COVERAGE
139		1.1 Location : bytesFrom Killed by : none negated conditional → NO_COVERAGE
140		1.1 Location : bytesFrom Killed by : none mutated return of Object value for org/maxur/perfmodel/backend/infrastructure/DataSourceLevelDbImpl::bytesFrom to ( if (x != null) null else throw new RuntimeException ) → NO_COVERAGE
146		1.1 Location : bytesFrom Killed by : none removed call to java/io/ObjectOutput::writeObject → NO_COVERAGE

DataSourceLevelDbImpl.java

Mutations

Active mutators

Tests examined