Excel导入数据库的Java代码
时间: 2023-09-18 19:05:52 浏览: 82
excel导入到数据库中的java代码
4星 · 用户满意度95%
### 回答1:
在导入Excel数据到数据库时,首先需要选择一个合适的 Java 框架或工具,以实现读取和解析 Excel 文件。一些常用的选择包括 Apache POI、JExcelAPI 和 OpenXLS。
以 Apache POI 为例,下面是一个简单的 Java 代码,用于从 Excel 文件读取数据并将其导入到数据库:
```
import java.io.FileInputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.util.Iterator;
import org.apache.poi.ss.usermodel.Cell;
import org.apache.poi.ss.usermodel.Row;
import org.apache.poi.xssf.usermodel.XSSFSheet;
import org.apache.poi.xssf.usermodel.XSSFWorkbook;
public class ExcelToDatabase {
public static void main(String[] args) {
try {
Class.forName("com.mysql.jdbc.Driver");
Connection connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/dbname", "username", "password");
PreparedStatement statement = connection.prepareStatement("INSERT INTO tablename (column1, column2, column3) VALUES (?, ?, ?)");
FileInputStream file = new FileInputStream("file.xlsx");
XSSFWorkbook workbook = new XSSFWorkbook(file);
XSSFSheet sheet = workbook.getSheetAt(0);
Iterator<Row> rowIterator = sheet.iterator();
while (rowIterator.hasNext()) {
Row row = rowIterator.next();
Iterator<Cell> cellIterator = row.cellIterator();
while (cellIterator.hasNext()) {
Cell cell = cellIterator.next();
switch (cell.getCellType()) {
case NUMERIC:
statement.setDouble(cell.getColumnIndex() + 1, cell.getNumericCellValue());
break;
case STRING:
statement.setString(cell.getColumnIndex() + 1, cell.getStringCellValue());
break;
}
}
statement.executeUpdate();
}
file.close();
connection.close();
} catch (Exception e) {
e.printStackTrace();
}
}
}
```
该代码使用了 Apache POI 库,用于读取 Excel 文件并将数据导入到 MySQL 数
### 回答2:
下面是一个使用Java代码将Excel文件导入数据库的示例:
```java
import java.io.FileInputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import org.apache.poi.ss.usermodel.*;
import org.apache.poi.xssf.usermodel.XSSFWorkbook;
public class ExcelImporter {
public static void main(String[] args) {
String excelFilePath = "path/to/excel/file.xlsx";
String dbUrl = "jdbc:mysql://localhost:3306/database_name";
String username = "username";
String password = "password";
try (Connection connection = DriverManager.getConnection(dbUrl, username, password);
FileInputStream fis = new FileInputStream(excelFilePath);
Workbook workbook = new XSSFWorkbook(fis)) {
Sheet sheet = workbook.getSheetAt(0);
int rowCount = sheet.getLastRowNum();
for (int i = 1; i <= rowCount; i++) {
Row row = sheet.getRow(i);
String column1 = row.getCell(0).getStringCellValue();
int column2 = (int) row.getCell(1).getNumericCellValue();
String column3 = row.getCell(2).getStringCellValue();
String sql = "INSERT INTO table_name (column1, column2, column3) VALUES (?, ?, ?)";
PreparedStatement statement = connection.prepareStatement(sql);
statement.setString(1, column1);
statement.setInt(2, column2);
statement.setString(3, column3);
statement.executeUpdate();
}
System.out.println("数据导入成功!");
} catch (SQLException e) {
e.printStackTrace();
} catch (Exception e) {
e.printStackTrace();
}
}
}
```
上述代码中,需要替换的部分包括excelFilePath(Excel文件路径)、dbUrl(数据库连接URL)、username(数据库用户名)、password(数据库密码)和sql(插入数据的SQL语句和表名)。然后,该代码会打开Excel文件,读取数据行,然后使用PreparedStatement将数据插入到数据库中。
请根据你的实际情况修改上述代码中的信息,然后将其运行在Java环境中,即可实现将Excel文件导入到数据库的操作。
### 回答3:
下面是一个示例的Java代码,可以通过使用Apache POI库将Excel文件导入到数据库中:
```java
import java.io.File;
import java.io.FileInputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import org.apache.poi.ss.usermodel.*;
public class ExcelImporter {
public static void main(String[] args) {
String excelFilePath = "path/to/excel/file.xlsx";
String dbUrl = "jdbc:mysql://localhost:3306/database_name";
String dbUser = "username";
String dbPassword = "password";
try {
// 创建数据库连接
Connection connection = DriverManager.getConnection(dbUrl, dbUser, dbPassword);
// 加载Excel文件
FileInputStream fis = new FileInputStream(new File(excelFilePath));
// 创建工作簿对象
Workbook workbook = WorkbookFactory.create(fis);
// 获取第一个工作表
Sheet sheet = workbook.getSheetAt(0);
// 迭代行
for (Row row : sheet) {
// 创建预编译的SQL语句
String sql = "INSERT INTO table_name (column1, column2, column3) VALUES (?, ?, ?)";
PreparedStatement statement = connection.prepareStatement(sql);
// 迭代列
for (Cell cell : row) {
// 获取单元格的值并设置参数
int columnIndex = cell.getColumnIndex();
switch (columnIndex) {
case 0:
statement.setString(1, cell.getStringCellValue());
break;
case 1:
statement.setInt(2, (int) cell.getNumericCellValue());
break;
case 2:
statement.setDate(3, new java.sql.Date(cell.getDateCellValue().getTime()));
break;
// 添加其他列的处理逻辑
}
}
// 执行插入操作
statement.executeUpdate();
// 关闭语句
statement.close();
}
// 关闭工作簿和文件流
workbook.close();
fis.close();
// 关闭数据库连接
connection.close();
System.out.println("Excel导入数据库成功!");
} catch (Exception e) {
e.printStackTrace();
}
}
}
```
请确保使用正确的Excel文件路径、数据库URL、用户名和密码来替换示例中的占位符。此代码将遍历Excel文件的第一个工作表的行和列,并将其值插入到数据库表中。您需要根据自己的需求修改SQL查询、数据库表名和列名,并添加适当的错误处理逻辑。
阅读全文