javasql代碼
import java.sql.Connection。
⑵ 關於在java中使用sql代碼
mport java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
public class ConnDB
{
public static void main(String[] args)
{
try
{
//我這里用mysql資料庫
Class.forName("com.mysql.jdbc.Driver");
String url = "jdbc:mysql://localhost:3306/mytest";
Connection conn = DriverManager.getConnection(url, "root", "123");
String sql = "select * from user limit ?,?";//這里沒有括弧
PreparedStatement ps = conn.prepareStatement(sql);
ps.setInt(1, 1);//為問號賦值
ps.setInt(2, 3);
ResultSet rs = ps.executeQuery();
while(rs.next())
{
System.out.println(rs.getString(2));
}
rs.close();
ps.close();
conn.close();
}
catch (Exception e)
{
e.printStackTrace();
}
}
}
希望對你有幫助
⑶ java程序連接sql server2008資料庫:求給一個具體的代碼，和過程。
連接資料庫
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;
public class TestDB {
public static void main(String[] args) {
try {
// 1.注冊驅動
Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");
System.out.println("注冊驅動成功");
String url = ""jdbc:microsoft.sqlserver://127.0.0.1:1433;DatabaseName="; //資料庫IP,埠,資料庫名
String username = "";
String password = "";
// 載入驅動並獲取資料庫連接對象
Connection connection = DriverManager.getConnection(url, username,
password);
System.out.println("連接資料庫成功！");
// 創建Statement對象
Statement stmt = connection.createStatement();
// SQL語句
String sql = "insert into student(id,name,age,email,address) values(1,'tom',23,'[email protected]','England') ";
int rows = stmt.executeUpdate(sql);
if (rows > 0) {
System.out.println("插入成功!");
}
// 釋放資源
stmt.close();
connection.close();
} catch (SQLException e) {
e.printStackTrace();
}
catch (ClassNotFoundException e) {
e.printStackTrace();
}
}
}
預編譯的資料庫處理
public class ConnectionManager{
public static final String DRIVER_CLASS ="";
public static final String URL = "";
public static final String USERNAME = "";
public static final String PASSWORD = "";
//獲取連接對象
public static Connection getConnection(){
Connection conn = null;
Class.forName(DRIVER_CLASS);
conn = DriverManager.getConnection(URL,USERNAME,PASSWORD);
return conn;
}
public static void closeAll(ResultSet rs,Statement stmt,Connection conn){
try{
if(rs!=null){
rs.close();
rs = null;
}
if(stmt!=null){
stmt.close();
stmt = null;
}
if(conn!=null){
conn.close();
conn=null;
}
}
}
}
public class DBOperator{
public int executeUpdate(String sql,Object[] params){
int rows = 0;
Connection connn = ConnectionManager.getConnection();
PreparedStatement pstmt = conn.prepareStatement(sql);
if(params!=null){
for(int i=0;i<params.length;i++){
pstmt.setObject(i+1,params[i]);//下標從1開始
}
}
rows = pstmt.executeUpdate();
ConnectionManager.closeAll(null,pstmt,conn);
return rows;
}
public ResultSet executeQuery(String sql,Object[] params){
Connetion conn = ConnectionManager.getConnection();
if(params!=null){
for(int i= 0;i<params.length;i++){
pstmt.setObject(i+1,params(i));
}
}
rs=pstmt.executeQuery();
ConnectionManager.closeAll(rs,pstmt,conn);
return rs;
}
}
/**
*statement連接資料庫
*/
public class TestOperatorGrade{
private static void updateGrade(int id,String name,String description){
Class.forName();//注冊驅動
Connection conn = DirverManager.getConnection("","","");
Statement stmt = conn.createStament();
String sql = "UPDATE grades set name = '"+name+"',description='"+description+"'WHere id="+id;
int rows = stmt.executeUpdate(sql);
}
}
這是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_admpdevice '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_admpdevice '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連接有問題代碼如下
資料庫連接好像有問題
static String url="jdbc:sqlserver://117.43.252.164;DatabaseName=pubs";
載入驅動程序，你好像寫得有問題，應該是這樣的
Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");
你再檢查下，祝你早日看到成功的結果。
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import com.microsoft.sqlserver.jdbc.SQLServerDriver;
public class TestDB {
public static void main(String[] args) {
try {
//載入驅動程序
Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");
//建立資料庫連接
String url = "jdbc:sqlserver://127.0.0.1:1433;databaseName=Movie";
Connection conn = DriverManager.getConnection(url, "用戶名", "密碼");
//創建域對象，用於執行sql語句
Statement stmt = conn.createStatement();
//執行SQL語句
String sql = "SELECT movieId,movieName,director,"
+ " typeID,stardom,region,showtime,"
+ " description,image,price FROM movies" ;
ResultSet rs = stmt.executeQuery(sql);
//使用結果 rs
while(rs.next()){
String mname = rs.getString("movieName");
double price = rs.getDouble("price");
System.out.println("名稱："+mname+"\t價格："+price);
}
rs.close();
stmt.close();
conn.close();
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}