Java Database Connectivity (JDBC) – A Simple Tutorial for Students

Welcome, future developers! If you’re looking to connect your Java applications with databases, you’re in the right place. Java Database Connectivity, commonly known as JDBC, is the bridge that links them together. It’s a powerful tool in a developer’s toolkit, allowing seamless interaction between Java and various databases. Dive into this tutorial, and by the end, you’ll have a clear understanding of the basics. Let’s embark on this journey together!

JDBC Architecture

When you think of JDBC, visualize it as a bridge. This bridge connects your Java application to a database. Central to this are the JDBC Drivers – they facilitate the actual connection. As for the inner workings, the JDBC API provides key components: DriverManager manages a list of database drivers, Connection connects to the actual database, Statement lets you run SQL queries, ResultSet fetches results, and PreparedStatement helps with pre-compiled SQL statements.

JDBC Architecture Diagram

Setting Up Your Environment

Before we dive deep, let’s set the stage. First, you’ll need to install a JDBC driver specific to the database you’re using. Now, balancing coding with school can be overwhelming. If you’re swamped with assignments, consider using services like Essay Pro to manage your workload. This way, you can allocate more time to coding. Once you’re set, proceed to set up a database for testing. This foundation is crucial for hands-on learning ahead.

Establishing a Connection

First things first: to chat with our database using Java, we need to establish a connection. Begin by loading the JDBC driver – think of it as dialing a friend’s number. Once that’s done, you can actually ‘call’ or connect to the database. It’s like establishing a direct line of communication between your Java code and the database.

try (Connection connection = 
        DriverManager.getConnection(URL, USERNAME, PASSWORD)) {
        ...
} catch (Exception e) {
    e.printStackTrace();
}

Executing SQL Statements

Now that we’re connected, let’s converse! Start by creating a Statement object. This is your tool to “speak” SQL. Whether you want to ask the database a question (query) or tell it to do something (update), the Statement object has your back.

Statement statement = connection.createStatement();
String query = "SELECT * FROM book";
ResultSet books = statement.executeQuery(query);

Working with ResultSet

So, you’ve asked your database a question. Where’s the answer? Enter ResultSet. As you iterate through the ResultSet, it’s like flipping through the pages of a book, gathering the information you asked for. Want specifics? You can retrieve data based on the column, making it easy to pinpoint exactly what you’re after.

while (books.next()) {
    System.out.println(books.getString("isbn") + ", " +
            books.getString("title") + ", " +
            books.getInt("published_year"));
}

Using PreparedStatement

Imagine sending a tailor-made invitation; it’s more efficient and safer. That’s what PreparedStatement offers over regular statements. This nifty tool lets you create SQL statements with placeholders, reducing errors and speeding things up. Once your structure is set, you can easily customize the message by filling in specific parameters. It’s like having a template for smoother, more personalized database interactions.

String orderDetailQuery = """
        INSERT INTO purchase_order_detail (order_id, product_id, quantity, price)
        VALUES (?, ?, ?, ?)
        """;

PreparedStatement detailStmt = conn.prepareStatement(orderDetailQuery);
detailStmt.setLong(1, 1L);
detailStmt.setInt(2, 1);
detailStmt.setInt(3, 10);
detailStmt.setBigDecimal(4, new BigDecimal("29.99"));
detailStmt.execute();

Handling SQL Exceptions

Even in the world of coding, things don’t always go as planned. When your Java application and the database have a miscommunication, SQL exceptions occur. But don’t fret! By catching an SQLException, you’re prepared to deal with these hiccups. This allows you to gracefully handle any bumps in the conversation. And the best part? You can retrieve specific error information, give you insights to troubleshoot and keep the conversation flowing smoothly.

Batch Processing with JDBC

Ever thought of sending multiple messages at once instead of one by one? That’s batch processing for you. In JDBC, this means executing multiple SQL commands in a single go. The perks? Faster operations and reduced server round trips. With addBatch() you line up your messages, and executeBatch() sends them all together in a neat package.

connection.setAutoCommit(false);
try (Statement statement = connection.createStatement()) {
    statement.addBatch("INSERT INTO product (code, name) " +
            "VALUE ('P0000006', 'Championship Manager')");
    statement.addBatch("INSERT INTO product (code, name) " +
            "VALUE ('P0000007', 'Transport Tycoon Deluxe')");

    int[] updateCounts = statement.executeBatch();
    System.out.println("updateCounts = " + Arrays.toString(updateCounts));
    connection.commit();
} catch (SQLException e) {
    connection.rollback();
    e.printStackTrace();
}

Transactions in JDBC

Think of a transaction as a promise. You’re telling the database, “I’ll make a series of changes, and if everything goes smoothly, let’s finalize them.” If something’s amiss, you can revert to the start, ensuring data integrity. This commitment is done using the ‘commit’ command. However, if there’s an issue, ‘rolling back’ undoes the changes, keeping your data safe and sound.

try (Connection conn =
             DriverManager.getConnection(URL, USERNAME, PASSWORD)) {
    conn.setAutoCommit(false);

    String orderQuery = """
            INSERT INTO purchase_order (username, order_date)
            VALUES (?, ?)
            """;

    try (PreparedStatement stmt = conn.prepareStatement(orderQuery,
            PreparedStatement.RETURN_GENERATED_KEYS)) {
        stmt.setString(1, "jduke");
        stmt.setDate(2, new Date(System.currentTimeMillis()));
        stmt.execute();

        ResultSet keys = stmt.getGeneratedKeys();
        long orderId = 1L;
        if (keys.next()) {
            orderId = keys.getLong(1);
        }

        // This is an invalid statement that will cause exception to
        // demonstrate a rollback.
        String orderDetailQuery = """
                INSERT INTO purchase_order_detail (order_id, product_id, quantity, price)
                VALUES (?, ?, ?, ?)
                """;

        PreparedStatement detailStmt = conn.prepareStatement(orderDetailQuery);
        detailStmt.setLong(1, orderId);
        detailStmt.setInt(2, 1);
        detailStmt.setInt(3, 10);
        detailStmt.setBigDecimal(4, new BigDecimal("29.99"));
        detailStmt.execute();

        // Commit transaction to mark it as a success database operation
        conn.commit();
        System.out.println("Transaction commit...");
    } catch (SQLException e) {
        // Rollback any database transaction due to exception occurred
        conn.rollback();
        System.out.println("Transaction rollback...");
        e.printStackTrace();
    }
} catch (Exception e) {
    e.printStackTrace();
}

Connection Pooling

Remember those kiddie pools filled with balls? Connection pooling is kinda like that, but for database connections. Instead of making a new connection each time, you just grab one from the pool. It’s faster and conserves resources. When you’re done, toss it back! And setting up? It’s a one-time thing to ensure a reservoir of ready connections.

Closing Resources and Best Practices

Always tidy up after a chat! In JDBC, this means closing the Connection, Statement, and ResultSet to free up resources. Ever heard of the try-with-resources statement? It’s a Java gem that ensures resources are closed properly. And a quick tip: if managing JDBC feels overwhelming with your academic load, consider the best dissertation writing service to help with school, so you can focus on coding right.

try (Connection conn =
             DriverManager.getConnection(URL, USERNAME, PASSWORD);
     Statement stmt = conn.createStatement();
     ResultSet rs = stmt.executeQuery("SELECT * FROM product")) {

    while (rs.next()) {
        String code = rs.getString("code");
        String name = rs.getString("name");

        System.out.println("Code: " + code + "; Name: " + name);
    }
} catch (SQLException e) {
    e.printStackTrace();
}

JDBC Limitations and Alternatives

JDBC is great, but it’s not perfect. For complex applications, it might feel a bit low-level or verbose. Enter ORM tools. They offer a more intuitive way to interact with databases, abstracting away much of the SQL. Think of them as an evolved, sophisticated version of JDBC for certain use cases.

Summary and Next Steps

And that’s a wrap! You’ve journeyed through JDBC’s landscape, grasped its core, and glimpsed its limitations. What’s next? Dive deeper, explore more advanced resources, and keep building. The coding world awaits your creations!

How do I create a string of repeated characters?

The following code demonstrates how to create a string of repeated characters. We use the String.repeat(int count) method introduced in Java 11. This method takes one parameter of type int which is the number of times to repeat the string. The count must be a positive number, a negative number will cause this method to throw java.lang.IllegalArgumentException.

In the snippet below, we use the method to repeat characters and draw some triangles. We combine the repeat() method with a for loop to draw the triangles.

package org.kodejava.basic;

public class StringRepeatDemo {
    public static void main(String[] args) {
        String star = "*";
        String fiveStars = star.repeat(5);
        System.out.println("fiveStars = " + fiveStars);

        String arrow = "-->";
        String arrows = arrow.repeat(10);
        System.out.println("arrows    = " + arrows);
    }
}

The outputs of the code snippet above are:

fiveStars = *****
arrows    = -->-->-->-->-->-->-->-->-->-->
package org.kodejava.basic;

public class StringRepeatDemo {
    public static void main(String[] args) {
        String asterisk = "#";
        for (int i = 1; i <= 10; i++) {
            System.out.println(asterisk.repeat(i));
        }
}

The outputs of the code snippet above are:

#
##
###
####
#####
######
#######
########
#########
##########
package org.kodejava.basic;

public class StringRepeatDemo {
    public static void main(String[] args) {
        int height = 10;
        for (int i = 1, j = 1; i <= height; i++, j += 2) {
            System.out.println(" ".repeat(height - i) + "*".repeat(j));
        }
    }
}

The outputs of the code snippet above are:

         *
        ***
       *****
      *******
     *********
    ***********
   *************
  ***************
 *****************
*******************

How do I convert datetime string with optional part to a date object?

Since JDK 8, we can create a datetime formatter / parser pattern that can have optional sections. When parsing a datetime string that contains optional values, for example, a date without time part or a datetime without second part, we can create a parsing pattern wrapped within the [] symbols. The [ character is the optional section start symbol, and the ] character is the optional section end symbol. The pattern inside this symbol will be considered as an optional value.

We can use the java.time.format.DateTimeFormatter class to parse the string of datetime or format the datetime object, and use it with the new Java time API classes such as java.time.LocalDate or java.time.LocalDateTime to convert the string into respective LocalDate or LocalDateTime object as show in the code snippet below.

package org.kodejava.datetime;

import java.time.LocalDate;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;

public class DateTimeParseOptionalParts {
    public static final String OPT_TIME_PATTERN = "yyyy-MM-dd[ HH:mm[:ss]]";
    public static final String OPT_SECOND_PATTERN = "yyyy-MM-dd HH:mm[:ss]";

    public static void main(String[] args) {
        DateTimeFormatter optTimeFormatter = DateTimeFormatter.ofPattern(OPT_TIME_PATTERN);
        LocalDate date1 = LocalDate.parse("2023-08-28", optTimeFormatter);
        LocalDate date2 = LocalDate.parse("2023-08-28 17:15", optTimeFormatter);
        LocalDate date3 = LocalDate.parse("2023-08-28 17:15:30", optTimeFormatter);
        System.out.println("date1 = " + date1);
        System.out.println("date2 = " + date2);
        System.out.println("date3 = " + date3);

        DateTimeFormatter optSecondFormatter = DateTimeFormatter.ofPattern(OPT_SECOND_PATTERN);
        LocalDateTime datetime1 = LocalDateTime.parse("2023-08-28 17:15", optSecondFormatter);
        LocalDateTime datetime2 = LocalDateTime.parse("2023-08-28 17:15:30", optSecondFormatter);
        System.out.println("datetime1 = " + datetime1);
        System.out.println("datetime2 = " + datetime2);
    }
}

Here are the outputs of the code snippet above:

date1 = 2023-08-28
date2 = 2023-08-28
date3 = 2023-08-28
datetime1 = 2023-08-28T17:15
datetime2 = 2023-08-28T17:15:30

How do I split large excel file into multiple smaller files?

A friend of mine told me that he has a large Excel file, and he asked me if I could split the file into multiple smaller Excel files. So I write this little program using Apache POI to do it.

The code snippet below basically contains the following steps:

  1. Load the Excel as an InputStream from the classpath, if the file was not found the program will exit.
  2. Create XSSFWorkbook from the input stream, and get the first XSSFSheet from the workbook.
  3. Iterate the rows of data from the source worksheet.
  4. On the first rownum for each split file we create a new workbook using SXSSFWorkbook and also create the SXSSFSheet.
  5. Read the first row from the source worksheet, store it in headerRow to be used for creating header row in each new sheet.
  6. If we are at the first row, write the header.
  7. Write each row from the source sheet to the destination sheet untuk the max rows is reached.
  8. Write the workbook into a new file.

And here is the complete code that you can try.

package org.kodejava.poi;

import org.apache.poi.ss.usermodel.Cell;
import org.apache.poi.ss.usermodel.CellType;
import org.apache.poi.ss.usermodel.Row;
import org.apache.poi.xssf.streaming.SXSSFCell;
import org.apache.poi.xssf.streaming.SXSSFRow;
import org.apache.poi.xssf.streaming.SXSSFSheet;
import org.apache.poi.xssf.streaming.SXSSFWorkbook;
import org.apache.poi.xssf.usermodel.XSSFRow;
import org.apache.poi.xssf.usermodel.XSSFSheet;
import org.apache.poi.xssf.usermodel.XSSFWorkbook;

import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.time.LocalDateTime;
import java.time.temporal.ChronoUnit;

public class SplitExcelDemo {
    public static final int MAX_ROWS_PER_FILE = 1000 - 1;
    public static final boolean WITH_HEADER = true;

    public static void main(String[] args) {
        LocalDateTime startTime = LocalDateTime.now();
        String filename = "/stock.xlsx";
        try (InputStream is = SplitExcelDemo.class.getResourceAsStream(filename)) {
            if (is == null) {
                System.out.println("Source file was not found!");
                System.exit(1);
            }

            XSSFWorkbook srcWorkbook = new XSSFWorkbook(is);
            XSSFSheet srcSheet = srcWorkbook.getSheetAt(0);
            int physicalNumberOfRows = srcSheet.getPhysicalNumberOfRows();

            int rownum = 0;
            int splitCounter = 0;

            SXSSFWorkbook destWorkbook = null;
            SXSSFSheet destSheet = null;

            XSSFRow headerRow = null;

            for (Row srcRow : srcSheet) {
                if (rownum == 0) {
                    // At the beginning let's create a new workbook and worksheet
                    destWorkbook = new SXSSFWorkbook();
                    destSheet = destWorkbook.createSheet();
                }

                if (srcRow.getRowNum() == 0 && WITH_HEADER) {
                    // Copy header row to be use in each split file
                    headerRow = (XSSFRow) srcRow;
                }

                if (rownum == 0 && WITH_HEADER) {
                    // Add row header to each split file
                    if (headerRow != null) {
                        SXSSFRow firstRow = destSheet.createRow(rownum);
                        int index = 0;
                        for (Cell cell : headerRow) {
                            SXSSFCell headerCell = firstRow.createCell(index++, cell.getCellType());
                            if (cell.getCellType() == CellType.STRING) {
                                headerCell.setCellValue(cell.getStringCellValue());
                            }
                        }
                    }
                } else {
                    // Copy rows from source worksheet into destination worksheet
                    SXSSFRow descRow = destSheet.createRow(rownum);
                    int index = 0;
                    for (Cell cell : srcRow) {
                        SXSSFCell destCell = descRow.createCell(index++, cell.getCellType());
                        switch (cell.getCellType()) {
                            case NUMERIC -> destCell.setCellValue(cell.getNumericCellValue());
                            case STRING -> destCell.setCellValue(cell.getStringCellValue());
                        }
                    }
                }

                // When a max number of rows copied are reached, or when we are at the end of worksheet, 
                // write data into a new file 
                if (rownum == MAX_ROWS_PER_FILE || srcRow.getRowNum() == physicalNumberOfRows - 1) {
                    rownum = -1;
                    String output = String.format("split-%03d.xlsx", splitCounter++);
                    System.out.println("Writing " + output);
                    try (OutputStream os = new FileOutputStream(output)) {
                        destWorkbook.write(os);
                    } catch (IOException e){
                        e.printStackTrace();
                    }
                }

                rownum = rownum + 1;
            }

            // Display processing time
            LocalDateTime endTime = LocalDateTime.now();
            long minutes = startTime.until(endTime, ChronoUnit.MINUTES);
            startTime = startTime.plusMinutes(minutes);
            long seconds = startTime.until(endTime, ChronoUnit.SECONDS);
            System.out.printf("Splitting finished in %d minutes and %d seconds %n", minutes, seconds);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

The output of running this program will look like this:

Writing split-000.xlsx
Writing split-001.xlsx
Writing split-002.xlsx
Writing split-003.xlsx
Writing split-004.xlsx
Writing split-005.xlsx
Writing split-006.xlsx
Writing split-007.xlsx
Writing split-008.xlsx
Writing split-009.xlsx
Splitting finished in 0 minutes and 8 seconds 

Maven Dependencies

<dependencies>
    <dependency>
        <groupId>org.apache.poi</groupId>
        <artifactId>poi</artifactId>
        <version>5.2.5</version>
    </dependency>
    <dependency>
        <groupId>org.apache.poi</groupId>
        <artifactId>poi-ooxml</artifactId>
        <version>5.2.5</version>
    </dependency>
</dependencies>

Maven Central Maven Central

How do I get the number of processors available to the JVM?

The Runtime.getRuntime().availableProcessors() method returns the maximum number of processors available to the Java virtual machine, the value will never be smaller than one. Knowing the number of available processor you can use it for example to limit the number of thread in your application when you are writing a multi-thread code.

package org.kodejava.lang;

public class NumberProcessorExample {
    public static void main(String[] args) {
        final int processors = Runtime.getRuntime().availableProcessors();
        System.out.println("Number of processors = " + processors);
    }
}

Running the code snippet give you something like:

Number of processors = 8