12888686285

Committed 21 Jan 2025 02:07PM UTC coverage: 50.829%. Remained the same

Build # 12888686285

Build Type

push

github

Committed by

torand

Commit Message

refactor: use instanceof variables

Coverage Stats

104 of 304 branches covered (34.21%)

Branch coverage included in aggregate %.

0 of 14 new or added lines in 1 file covered. (0.0%)

601 of 1083 relevant lines covered (55.49%)

2.91 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/src/main/java/io/github/torand/fastersql/statement/PreparedStatementBuilder.java

/*
 * Copyright (c) 2024 Tore Eide Andersen
 *
 * 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 io.github.torand.fastersql.statement;

import io.github.torand.fastersql.Context;
import io.github.torand.fastersql.dialect.Dialect;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.io.InputStream;
import java.net.URI;
import java.sql.*;
import java.time.Instant;
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.util.List;
import java.util.UUID;

/**
 * Builder for creating PreparedStatement with a Connection.
 */
public class PreparedStatementBuilder {
    private static final Logger LOGGER = LoggerFactory.getLogger(PreparedStatementBuilder.class);
    private final Connection connection;

    public static PreparedStatementBuilder using(Connection connection) {
        return new PreparedStatementBuilder(connection);
    }

    private PreparedStatementBuilder(Connection connection) {
        this.connection = connection;
    }

    public PreparedStatement prepare(PreparableStatement statement) throws SQLException {
        LOGGER.debug("Preparing SQL statement: {}", statement);

        Context context = Context.of(Dialect.fromConnection(connection));
        String sql = statement.sql(context);
        List<Object> params = statement.params(context);

        PreparedStatement stmt = connection.prepareStatement(sql);
        int i = 1;
        for (Object param : params) {
            if (param instanceof Instant instant) {
                stmt.setTimestamp(i, Timestamp.from(instant));
            } else if (param instanceof LocalDateTime localDateTime) {
                stmt.setTimestamp(i, Timestamp.valueOf(localDateTime));
            } else if (param instanceof LocalDate localDate) {
                stmt.setDate(i, Date.valueOf(localDate));
            } else if (param instanceof UUID uuid) {
                stmt.setObject(i, uuid.toString());
            } else if (param instanceof URI uri) {
                stmt.setObject(i, uri.toString());
            } else if (param instanceof Enum enumValue) {
                stmt.setObject(i, enumValue.name());
            } else if (param instanceof InputStream inputStream) {
                stmt.setBinaryStream(i, inputStream);
            } else {
                stmt.setObject(i, param);
            }

            i++;
        }

        return stmt;
    }
}

1	/*
2	* Copyright (c) 2024 Tore Eide Andersen
3	*
4	* Licensed under the Apache License, Version 2.0 (the "License");
5	* you may not use this file except in compliance with the License.
6	* You may obtain a copy of the License at
7	*
8	* http://www.apache.org/licenses/LICENSE-2.0
9	*
10	* Unless required by applicable law or agreed to in writing, software
11	* distributed under the License is distributed on an "AS IS" BASIS,
12	* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13	* See the License for the specific language governing permissions and
14	* limitations under the License.
15	*/
16	package io.github.torand.fastersql.statement;
17
18	import io.github.torand.fastersql.Context;
19	import io.github.torand.fastersql.dialect.Dialect;
20	import org.slf4j.Logger;
21	import org.slf4j.LoggerFactory;
22
23	import java.io.InputStream;
24	import java.net.URI;
25	import java.sql.*;
26	import java.time.Instant;
27	import java.time.LocalDate;
28	import java.time.LocalDateTime;
29	import java.util.List;
30	import java.util.UUID;
31
32	/**
33	* Builder for creating PreparedStatement with a Connection.
34	*/
35	public class PreparedStatementBuilder {
36	private static final Logger LOGGER = LoggerFactory.getLogger(PreparedStatementBuilder.class);	×
37	private final Connection connection;
38
39	public static PreparedStatementBuilder using(Connection connection) {
40	return new PreparedStatementBuilder(connection);	×
41	}
42
43	private PreparedStatementBuilder(Connection connection) {	×
44	this.connection = connection;	×
45	}	×
46
47	public PreparedStatement prepare(PreparableStatement statement) throws SQLException {
48	LOGGER.debug("Preparing SQL statement: {}", statement);	×
49
50	Context context = Context.of(Dialect.fromConnection(connection));	×
51	String sql = statement.sql(context);	×
52	List<Object> params = statement.params(context);	×
53
54	PreparedStatement stmt = connection.prepareStatement(sql);	×
55	int i = 1;	×
56	for (Object param : params) {	×
NEW 57	if (param instanceof Instant instant) {	×
NEW 58	stmt.setTimestamp(i, Timestamp.from(instant));	×
NEW 59	} else if (param instanceof LocalDateTime localDateTime) {	×
NEW 60	stmt.setTimestamp(i, Timestamp.valueOf(localDateTime));	×
NEW 61	} else if (param instanceof LocalDate localDate) {	×
NEW 62	stmt.setDate(i, Date.valueOf(localDate));	×
NEW 63	} else if (param instanceof UUID uuid) {	×
NEW 64	stmt.setObject(i, uuid.toString());	×
NEW 65	} else if (param instanceof URI uri) {	×
NEW 66	stmt.setObject(i, uri.toString());	×
NEW 67	} else if (param instanceof Enum enumValue) {	×
NEW 68	stmt.setObject(i, enumValue.name());	×
NEW 69	} else if (param instanceof InputStream inputStream) {	×
NEW 70	stmt.setBinaryStream(i, inputStream);	×
71	} else {
72	stmt.setObject(i, param);	×
73	}
74
75	i++;	×
76	}	×
77
78	return stmt;	×
79	}
80	}

torand / FasterSQL / 12888686285

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous