
public
void
read()
{
try
{
//连接数据库
conn
=
JdbcUtilsgetConnection();
//查询resume字段,text格式
String
sql
=
"select
resume
from
testclob
where
id=1";
pt
=
connprepareStatement(sql);
//执行查询并返回结果
rs
=
ptexecuteQuery();
if
(rsnext())
{
//
rsgetCharacterStream读取该字段
Reader
reader
=
rsgetCharacterStream("resume");
//定义字符数组来存放读取值
char
buffer[]
=
new
char[1024];
while
((readerread(buffer))
!=
-1)
{
//打印
Systemoutprintln(buffer);
}
readerclose();
}
}
catch
(Exception
e)
{
eprintStackTrace();
}
finally
{
JdbcUtilsrelease(conn,
pt,
rs);
}
}
用JDBC连接数据库,然后用sql语句。要导入mysql的驱动包。
importjavasql;
publicclassTestMySql{
staticConnectioncon=null;//声明Connection对象
staticStatementsql=null;
staticResultSetres=null;
publicstaticvoidmain(String[]args){
TestMySqlc=newTestMySql();
con=c();
try{
sql=con();
res=sql("selectfromdept");
//sql语句,我数据库里有张dept表
while(resnext()){//输出结果
Systemoutprint(resgetString(1)"
Systemoutprint(resgetString(2)"
Systemoutprint(resgetString(3));
Systemoutprintln();
}
}catch(e){
e();
}finally{
try{
if(res!=null){
resclose();
res=null;
}
if(sql!=null){
sqlclose();
sql=null;
}
if(con!=null){
conclose();
con=null;
}
}catch(e){
e();
}
}
}
publicConnection(){
try{
ClassforName("commysqljdbcDriver");
//加载oracleJDBC驱动
Systemoutprintln("数据库驱动加载成功");
}catch(e){
e();
}
try{//通过访问数据库的URL获取数据库连接对象
con=(
"jdbc:mysql://localhost:3306/mydata","root","qwer1234");
//mydata为mysql名字
Systemoutprintln("数据库连接成功");
}catch(e){
e();
}
returncon;//按方法要求返回一个Connection对象
}
}
package comextranautsshixun2mdbtools;
import javaioIOException;
import javasqlConnection;
import javasqlDriverManager;
import javasqlPreparedStatement;
import javasqlResultSet;
import javasqlSQLException;
import javautilProperties;
public class DBUtils {
private static Properties p = new Properties();
private static DBUtils d = new DBUtils();
static{
try {
pload(dgetClass()getResourceAsStream("initproperties"));
} catch (IOException e) {
Systemoutprintln("配置文件不存在" + egetMessage());
}
}
public static Connection getConnection() {
Connection con = null;
// 加载配置文件
// 提取配置文件中的项
// 读取配置文件中的数据库连接项
String ip = pgetProperty("ip")trim();
String dbtype = pgetProperty("dbtype")trim();
String dbname = pgetProperty("dbname")trim();
String port = pgetProperty("port")trim();
String username = pgetProperty("username")trim();
String password = pgetProperty("password")trim();
// 判断链接数据库的种类
if (dbtypeequalsIgnoreCase("mysql")) {
// 创建链接
try {
ClassforName("orggjtmmmysqlDriver");
} catch (ClassNotFoundException e) {
Systemoutprintln("mysql驱动未找到" + egetMessage());
}
StringBuffer s = new StringBuffer();
sappend("jdbc:mysql://");
sappend(ip);
sappend(":");
sappend(port);
sappend("/");
sappend(dbname);
sappend("user=");
sappend(username);
sappend("&password=");
sappend(password);
sappend("&useUnicode=true&characterEncoding=gb2312");
// myDB为数据库名
try {
con= DriverManagergetConnection(stoString());
} catch (SQLException e) {
Systemoutprintln("数据库连接项不正确" + egetMessage());
}
}
if (dbtypeequalsIgnoreCase("sqlserver")) {
// 创建链接
try {
ClassforName("commicrosoftjdbcsqlserverSQLServerDriver");
} catch (ClassNotFoundException e) {
Systemoutprintln("sqlserver驱动未找到" + egetMessage());
}
StringBuffer s = new StringBuffer();
sappend("jdbc:microsoft:sqlserver://");
sappend(ip);
sappend(":");
sappend(port);
sappend(";DatabaseName=");
sappend(dbname);
// mydb为数据库
try {
con= DriverManagergetConnection(stoString(),username,password);
} catch (SQLException e) {
Systemoutprintln("数据库连接项不正确" + egetMessage());
}
}
// if (dbtypeequals("oracle")) {
//// 创建链接
// try {
// ClassforName("oraclejdbcdriverOracleDriver");
// } catch (ClassNotFoundException e) {
// Systemoutprintln("oracle数据库驱动未找到" + egetMessage());
// }
// String url="jdbc:oracle:thin:@"+ip+":"+port+":"+dbname;
//// orcl为数据库的SID
// try {
// con= DriverManagergetConnection(url,username,password);
// } catch (SQLException e) {
// Systemoutprintln("数据库连接项不正确" + egetMessage());
// }
// }
return con;
}
public static void close(Connection con,PreparedStatement pstam , ResultSet rs){
if(con != null){
try {
conclose();
} catch (SQLException e) {
// TODO Auto-generated catch block
eprintStackTrace();
}
}
if(pstam != null){
try {
pstamclose();
} catch (SQLException e) {
// TODO Auto-generated catch block
eprintStackTrace();
}
}
if(rs != null){
try {
rsclose();
} catch (SQLException e) {
// TODO Auto-generated catch block
eprintStackTrace();
}
}
}
}
没顾上看你的 这是我以前用过的
以上就是关于怎样读取mysql数据库文本(text)字段的值全部的内容,包括:怎样读取mysql数据库文本(text)字段的值、java中怎么获取mysql数据库的数据(java获取mysql数据库列表)、jdbc连接mysql数据库失败的原因等相关内容解答,如果想了解更多相关内容,可以关注我们,你们的支持是我们更新的动力!
欢迎分享,转载请注明来源:内存溢出
微信扫一扫
支付宝扫一扫
评论列表(0条)