sql数据库java代码 java数据库代码实例
java中 sql数据库备份代码怎么写
最简单的SQL语句：备份与还原SQL Server自带的数据库
创新互联专业为企业提供南昌县网站建设、南昌县做网站、南昌县网站设计、南昌县网站制作等企业网站建设、网页设计与制作、南昌县企业网站模板建站服务，十余年南昌县做网站经验，不只是建网站，更提供有价值的思路和整体网络服务。
在服务器上备份：
use Northwind
Backup database Northwind to disk='d:\Northwind_bak.dat' with init
RESTORE DATABASE NorthNwind FROM DISK = 'd:\Northwind_bak.dat'
备份数据库这一操作在客户机上实现
客户机：machine
共享目录：share （要完全共享，可写权限）
backup:
bakcup database dbname to disk='\\machine\share\data.bak' with init
\\machine\share目录要有写权限。
restore:
restore database dbname from disk='\\machine\share\data.bak'
//
备注：restore 语句有很多的选项，可以查看企业管理器的在线帮助。如下
with replace, move 'dbname_dat' to 'c:\mssql7\data\dbname.mdf',
move 'dbname_log' to 'c:\mssql7\data\dbname.log'
其中'c:\mssql7\data\'是服务器的目录，这点要注意
备份与还原数据库的相关内容：
SQL Server 7.0数据库备份有四种：完全数据库备份、增量数据库备份、事务日志备份、数据库文件或文件组备份。在数据库崩溃时，应该首先尝试备份事务日志（这一点很重要），然后恢复最后的数据库备份、该次数据库备份后的所有增量备份，最后恢复事务日志备份，这样可以将数据库恢复到崩溃前的状态。
备份是定期的，而不是实时的，所以利用备份并不能完全恢复数据库，它只能将数据库恢复到制作备份的那一刻 ...... 数据库日志是实时的，他忠实的记录下所有对数据库的更新操作。因此，当磁盘出现故障造成数据库损坏时，就可以首先利用备份恢复数据库（大部分数据），然后运行数据库日志，即将备份后所做的操作重新在做一遍，从而将数据库完全恢复。
--备份完整的数据库---------------------------------------------------------------
//创建一个备份设备：
1. Create the backup device for the full MyNwind backup.///
USE master
EXEC sp_addumpdevice 'disk', 'MyNwind_2', 'c:\mssql7\backup\MyNwind_2.dat'
2. Back up the full MyNwind database.
BACKUP DATABASE MyNwind TO MyNwind_2
--备份数据库的日志---------------------------------------------------------------
--1. Create the log backup device.
USE master
EXEC sp_addumpdevice 'disk', 'MyNwindLog1', 'c:\mssql7\backup\MyNwindLog1.dat'
--2. Update activity has occurred before this point. Back up the log of the MyNwind database.
BACKUP LOG MyNwind TO MyNwindLog1
try
AdoQuery1.Close;
AdoQuery1.SQL.Clear;
AdoQuery1.SQL.Add('backup database pubs');
AdoQuery1.SQL.Add('to disk='+''''+edtPath.Text+'''');
AdoQuery1.ExecSQL;
except
ShowMessage('备份数据库失败！');
exit;
end;
SQL server的备份
=========================================================================
=========================================================================
备份：
with adocommand_restore do//用ADocommand控件
begin
CommandText:='use Master';//
Execute;
CommandText:='execute sp_helpdevice';//系统存储过程
Execute ;
CommandText:='backup database '+'db_name'+' to disk='''+FileName+''' with init';//这行应当是这样
Execute ;
CommandText:='Use '+'db_name';//这行应当是这样
Execute ;
application.MessageBox('已经成功备份数据库','数据库备份',MB_OK + MB_ICONINFORMATION);
end;
恢复：
with adocommand1 do//用AdoCommand控件
begin
CommandText:='use Master';
Execute;
CommandText:='execute sp_helpdevice';
Execute ;
CommandText:='Restore database '+'db_name'+' From disk='''+'c:\data1.bak'+''' with replace';//这行应当是这样
Execute ;
CommandText:='Use '+'db_name';//这行应当是这样
Execute ;
application.MessageBox('已经成功恢复数据库','数据库恢复',MB_OK + MB_ICONINFORMATION);
end;
*注：db_name指数据库的名称
java连接数据库的代码
package mysql;
import java.sql.*;
/**
* @author xys
*/
public class ConnectMysql {
public static Connection getConnection() throws ClassNotFoundException, SQLException {
String url = "jdbc:mysql://localhost:3306/databaseName";
String user = "mysqluser";
String password = "password";
String driverClass = "com.mysql.cj.jdbc.Driver";
Connection connection = null;
Class.forName(driverClass);
try {
connection = DriverManager.getConnection(url, user, password);
} catch (SQLException e) {
e.printStackTrace();
}
if (connection != null) {
System.out.println("数据库连接成功");
} else {
System.out.println("数据库连接失败");
connection.close();
}
return connection;
}
public void getResult() throws ClassNotFoundException, SQLException {
// 实例化 Statement 对象
Statement statement = getConnection().createStatement();
// 要执行的 Mysql 数据库操作语句（增、删、改、查）
String sql = "";
// 展开结果集数据库
ResultSet resultSet = statement.executeQuery(sql);
while (resultSet.next()) {
// 通过字段检索
int id = resultSet.getInt("id");
String name = resultSet.getString("name");
// 输出数据
System.out.println("ID : " +id);
System.out.println("name :" + name);
}
// 完成后需要依次关闭
resultSet.close();
statement.close();
getConnection().close();
}
}
java如何实现sql连接和查询的代码？
import java.sql.Connection。
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;
import javax.sql.DataSource;
public class DBCon {
//数据库驱动对象
public static final String DRIVER="oracle.jdbc.driver.OracleDriver";
//数据库连接地址(数据库名)
public static final String URL="jdbc:oracle:thin:@localhost:1521:orcl";
//登陆名
public static final String USER="FM";
//登陆密码
public static final String PWD="FM";
//创建数据库连接对象
private Connection con=null;
//创建数据库预编译对象
private PreparedStatement ps=null;
//创建结果集
private ResultSet rs=null;
//创建数据源对象
public static DataSource source=null;
// //静态代码块
// static{
//
// //初始化配置文件context
// try {
// Context context=new InitialContext();
// source=(DataSource)context.lookup("java:comp/env/jdbc/webmessage");
// } catch (Exception e) {
// // TODO Auto-generated catch block
// e.printStackTrace();
// }
//
//
// }
/**
* 获取数据库连接
*/
public Connection getCon(){
try {
Class.forName(DRIVER);
} catch (ClassNotFoundException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
try {
con=DriverManager.getConnection(URL,USER,PWD);
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return con;
}
// /**
// * 获取数据库连接
// */
// public Connection getCon(){
//
// try {
// con=source.getConnection();
// } catch (SQLException e) {
// // TODO Auto-generated catch block
// e.printStackTrace();
// }
//
// return con;
// }
/**
* 关闭所有资源
*/
public void closeAll(){
if(rs!=null)
try {
rs.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
if(ps!=null)
try {
ps.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
if(con!=null)
try {
con.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
/**
* @param sql数据库更新(增、删、改) 语句
* @param pras参数列表（可传，可不传，不传为NULL，以数组形式存在）
* @return 返回受影响都行数
*/
public int update(String sql,String... pras){
int resu=0;
con=getCon();
try {
ps=con.prepareStatement(sql);
for(int i=0;ipras.length;i++){
ps.setString(i+1,pras[i]);
}
resu=ps.executeUpdate();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
finally{
closeAll();
}
return resu;
}
/**
* @param sql数据库查询语句
* @param pras参数列表（可传，可不传，不传为NULL，以数组形式存在）
* @return 返回结果集
*/
public ResultSet query(String sql,String... pras){
con=getCon();
try {
ps=con.prepareStatement(sql);
if(pras!=null)
for(int i=0;ipras.length;i++){
ps.setString(i+1, pras[i]);
}
rs=ps.executeQuery();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return rs;
}
}
分享标题：sql数据库java代码 java数据库代码实例
文章起源：http://azwzsj.com/article/doiidho.html
