//此类为连接
数据库并进行
数据库的 *** 作\x0d\x0aimportjava.sql.Connection\x0d\x0aimportjava.sql.DriverManager\x0d\x0aimportjava.sql.ResultSet\x0d\x0aimportjava.sql.SQLException\x0d\x0aimportjava.sql.Statement\x0d\x0apublicclassConn{\x0d\x0aprivatestaticConnectionconn=null\x0d\x0aprivatestaticStatementst=null\x0d\x0aprivatestaticResultSetrs=null\x0d\x0a//建立数据库的连接\x0d\x0apublicConn(){\x0d\x0aStringurl="jdbc:sqlserver://localhost:1433databaseName=ZYGX"\x0d\x0aStringuser="sa"\x0d\x0aStringpassword="123"\x0d\x0atry{\x0d\x0aClass.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver")\x0d\x0aconn=DriverManager.getConnection(url,user,password)\x0d\x0ast=conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY)\x0d\x0a}catch(ClassNotFoundExceptione){\x0d\x0ae.printStackTrace()\x0d\x0a}catch(SQLExceptione){\x0d\x0ae.printStackTrace()\x0d\x0a}\x0d\x0a}\x0d\x0a\x0d\x0a//通过不同的sql语句,得到相应Resultset结果集\x0d\x0apublicResultSetgetRs(Stringsql){\x0d\x0atry{\x0d\x0ars=st.executeQuery(sql)\x0d\x0a}catch(SQLExceptione){\x0d\x0ae.printStackTrace()\x0d\x0a}\x0d\x0areturnrs\x0d\x0a}\x0d\x0a//根据不同的sql语句,执行数据库的更新 *** 作\x0d\x0apublicintupdata(Stringsql){\x0d\x0aintnum=0\x0d\x0atry{\x0d\x0anum=st.executeUpdate(sql)\x0d\x0a}catch(SQLExceptione){\x0d\x0ae.printStackTrace()\x0d\x0a}\x0d\x0areturnnum\x0d\x0a}\x0d\x0a//关闭数据库连接相应的资源\x0d\x0apublicvoidclose(){\x0d\x0atry{\x0d\x0aif(rs!=null){\x0d\x0ars.close()\x0d\x0ars=null\x0d\x0a}\x0d\x0aif(st!=null){\x0d\x0ast.close()\x0d\x0ast=null\x0d\x0a}\x0d\x0aif(conn!=null){\x0d\x0aconn.close()\x0d\x0aconn=null\x0d\x0a}\x0d\x0a}catch(SQLExceptione){\x0d\x0ae.printStackTrace()\x0d\x0a}\x0d\x0a}\x0d\x0a}\x0d\x0a----------------------------------------------------------------------\x0d\x0a//可以对button里添加动作按钮:\x0d\x0afinalJButtonbutton=newJButton()\x0d\x0abutton.addActionListener(newActionListener(){\x0d\x0apublicvoidactionPerformed(finalActionEvente){\x0d\x0aConnconn=newConn()\x0d\x0aStringsql1="select*fromaawherename='"+name+"'"//按name值查找\x0d\x0aResultSetrs=conn.getRs(sql1)\x0d\x0atry{\x0d\x0awhile(rs.next()){\x0d\x0aintn=rs.getString("type")\x0d\x0a}\x0d\x0a}catch(SQLExceptione){\x0d\x0ae.printStackTrace()\x0d\x0a}\x0d\x0aStringname=textField.getText()\x0d\x0aStringsql="updateaasettittle='"+name+"'"//从aa表将title字段的值改成textField里的name值\x0d\x0aStringsql2="deletefromaawherename='"+name+"'"//从aa表将按取得name的值删除该行数据\x0d\x0aStringsql3="insertintoaa(name,uname)values('"+name+"','"')"//将name,uname值新增到aa表\x0d\x0aif(conn.update(sql)==1){\x0d\x0aSystem.out.print("修改成功")\x0d\x0a}\x0d\x0aif(conn.update(sql2)==1){\x0d\x0aSystem.out.print("删除成功")\x0d\x0a}\x0d\x0aif(conn.update(sql3)==1){\x0d\x0aSystem.out.print("新增成功")\x0d\x0a}\x0d\x0a}\x0d\x0a})
主要的几个点:
1、确定表有多少行。
2、按表的行数画表格。
给你个示列
import java.awt.BorderLayout
import java.awt.Color
import java.awt.Font
import java.beans.Statement
import java.sql.Connection
import java.sql.DriverManager
import java.sql.ResultSet
import java.sql.SQLException
import java.util.Vector
第一步:如何用POI *** 作Excel
@Test
public void createXls() throws Exception{
//声明一个工作薄
HSSFWorkbook wb = new HSSFWorkbook()
//声明表
HSSFSheet sheet = wb.createSheet("第一个表")
//声明行
HSSFRow row = sheet.createRow(7)
//声明列
HSSFCell cel = row.createCell(3)
//写入数据
cel.setCellValue("你也好")
FileOutputStream fileOut = new FileOutputStream("d:/a/b.xls")
wb.write(fileOut)
fileOut.close()
}
第二步:导出指定数据库的所有表
分析:
1:某个数数据库有多少表,表名是什么?―――DataBaseMetadate.getMetadate().getTables(null,null,null,new String[]{Table}) - excel的文件名称。
2:对每一个表进行select * *** 作。 - 每一个sheet的名称。
3:分析表结构,rs.getMetadate()ResultSetMedated
4:多个列,列名是什么.- 字段名就是sheet的第一行信息。
5:获取每一行的数据 – 放到sheet第一行以后。
@Test
public void export() throws Exception{
//声明需要导出的数据库
String dbName = "focus"
//声明book
HSSFWorkbook book = new HSSFWorkbook()
//获取Connection,获取db的元数据
Connection con = DataSourceUtils.getConn()
//声明statemen
Statement st = con.createStatement()
//st.execute("use "+dbName)
DatabaseMetaData dmd = con.getMetaData()
//获取数据库有多少表
ResultSet rs = dmd.getTables(dbName,dbName,null,new String[]{"TABLE"})
//获取所有表名 - 就是一个sheet
List<String>tables = new ArrayList<String>()
while(rs.next()){
String tableName = rs.getString("TABLE_NAME")
tables.add(tableName)
}
for(String tableName:tables){
HSSFSheet sheet = book.createSheet(tableName)
//声明sql
String sql = "select * from "+dbName+"."+tableName
//查询数据
rs = st.executeQuery(sql)
//根据查询的结果,分析结果集的元数据
ResultSetMetaData rsmd = rs.getMetaData()
//获取这个查询有多少行
int cols = rsmd.getColumnCount()
//获取所有列名
//创建第一行
HSSFRow row = sheet.createRow(0)
for(int i=0i<colsi++){
String colName = rsmd.getColumnName(i+1)
//创建一个新的列
HSSFCell cell = row.createCell(i)
//写入列名
cell.setCellValue(colName)
}
//遍历数据
int index = 1
while(rs.next()){
row = sheet.createRow(index++)
//声明列
for(int i=0i<colsi++){
String val = rs.getString(i+1)
//声明列
HSSFCell cel = row.createCell(i)
//放数据
cel.setCellValue(val)
}
}
}
con.close()
book.write(new FileOutputStream("d:/a/"+dbName+".xls"))
}
评论列表(0条)