java 读取mysql中数据 并取出
时间：2021-07-01 10:21:17
帮助过：2人阅读
static String url =
null;
public static String username =
null;
public static String password =
null;
public static Connection conn;
public static Statement stmt;
public static ResultSet rs;
public static String fileName =
null;
public static List lists =
new ArrayList();
public static String PATH = "/dbconfig.properties"
;
private static Properties properties;
static {
try {
InputStream is = DBlUtils.
class.getResourceAsStream(PATH);
properties =
new Properties();
properties.load(is);
url = properties.getProperty("jdbc.url"
);
username = properties.getProperty("jdbc.username"
);
password = properties.getProperty("jdbc.password"
);
fileName = properties.getProperty("fileName"
);
System.out.println("fileName:" +
fileName);
if (is !=
null)
is.close();
} catch (IOException e) {
e.printStackTrace();
}
}
public void closeConnection(Connection conn) {
if (conn !=
null) {
try {
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
/**
* 查询mysql 数据库数据，并获得内容
*
* @param sql
*/
public static void queryDatas(String sql) {
List<BnsWord> listsDatas =
new ArrayList<BnsWord>
();
BnsWord bw =
new BnsWord();
// bw.setContent("content");
try {
conn =
DriverManager.getConnection(url, username, password);
conn.setAutoCommit(false);
stmt = conn.prepareStatement("load data local infile ‘‘ " + "into table loadtest fields terminated by ‘,‘"
);
StringBuilder sb =
new StringBuilder();
InputStream is =
new ByteArrayInputStream(sb.toString().getBytes());
((com.mysql.jdbc.Statement) stmt).setLocalInfileInputStream(is);
ResultSet rs =
stmt.executeQuery(sql);
ResultSetMetaData rsmd =
rs.getMetaData();
int columnCount =
rsmd.getColumnCount();
// 输出列名
for (
int i = 1; i <= columnCount; i++
) {
System.out.print(rsmd.getColumnName(i));
System.out.print("(" + rsmd.getColumnTypeName(i) + ")"
);
System.out.print(" | "
);
}
System.out.println();
// 输出数据
while (rs.next()) {
for (
int i = 1; i <= columnCount; i++
) {
System.out.print(rs.getString(i) + " | "
);
}
System.out.println();
}
// conn.commit();
}
catch (SQLException e) {
e.printStackTrace();
}
}
public static void main(String[] args) {
String sql = "select * from tablename";
queryDatas(sql);
}
java 读取mysql中数据 并取出
标签：
