資料庫源碼例子

❶ 資料庫中間件-cetus源碼介紹

資料庫中間件Cetus的源碼介紹將重點放在其內部流程的解析上。從啟動開始，Cetus的執行流程主要從src/mysql-proxy-cli.c文件的main函數出發，調用main_cmdline函數。在正常情況下，啟動service後，流程會進入main_cmdline函數中的chassis_mainloop。

chassis_mainloop函數將調用cetus_master_process_cycle，該過程一直傳遞chassis結構，其包含關鍵元素。在cetus_master_process_cycle中，程序開啟worker_process，主要在cetus_spawn_process函數中進行，之後進入cetus_worker_process_cycle進行初始化。

worker_process通過死循環調用主進程chassis_event_loop，並監聽客戶端消息。在執行流程中，會經過event_base_loop和ev_run等函數，進一步處理事件。

具體任務處理流程從event_base_loop開始，調用ev_run、ev_invoke_pending、ev_x_cb_io、ev_x_cb，最終到達network_mysqld_con_handle處理傳入的SQL語句，並將它們賦值給con->orig_sql。接下來調用normal_read_query_result函數，此函數調用network_mysqld_read_rw_resp處理與後端資料庫的消息，並基於返回結果進行後續操作。

總結，Cetus源碼中，從啟動至執行流程，再到任務處理，構成了一個完整的資料庫中間件執行邏輯。其核心在於通過一系列函數調用，實現消息的傳遞、處理和最終反饋，確保數據的高效、准確處理。流程清晰，結構嚴謹，體現了Cetus在資料庫中間件領域的專業性和高效性。

❷ 求一個簡單又經典的java與資料庫例子,要有源代碼哦!

//下面的是連接mysql的例子
package com.song.struts.mySql;

import javax.swing.JComponent;
import java.sql.*;
import java.util.*;
// import com.borland.dx.sql.dataset.*;

public class mySqlDao extends JComponent {
private String UserName="root";
private String PWD="root";
private String url;
private Connection cn;
private Statement stmt;
private ResultSet rs = null;
public mySqlDao(){
try {
Class.forName("org.gjt.mm.mysql.Driver");
}
catch(java.lang.ClassNotFoundException e){
System.err.println("mydb() org.gjt.mm.mysql.Driver: " + e.getMessage());
}
catch(Exception e) {
e.printStackTrace();
}

}
//////////////////////////////
///返回mysql 連接,connection
/////////////////////////////
public Connection Connect(String dbname,String ip){
try{
String hostip=ip;
Properties myP = new Properties();
myP.setProperty("useUnicode","true");
myP.setProperty("characterEncoding","GB2312");
url="jdbc:mysql://"+hostip+":3306/"+dbname+"?user="+UserName+"&password="+PWD+"";
if(cn!=null){
cn.close();
}
cn=DriverManager.getConnection(url,myP);
stmt= cn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_UPDATABLE);
System.out.println("db connect success");
return cn;
}
catch(Exception e){
System.err.println("db connect err"+e.getMessage());
return null;
}
}
//////////////////////////////////
///關閉連接
/////////////////////////////////
public void close(){
try{
if(stmt!=null){
stmt.close();
}
if(cn!=null){
cn.close();
}
System.err.println("db colse success");
}
catch(Exception e){
System.err.println("db close err"+e.getMessage());
}
}
/////////////////////////////////////////////
// 用於進行記錄的查詢操�?,用於select 語句�?
//參數:sql語句�?
//返回:ResultSet對象
///////////////////////////////////////////
public ResultSet executeSelect(String sql) {
try {
stmt=cn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_UPDATABLE);
rs = stmt.executeQuery(sql);
return rs;
}
catch(SQLException ex) {
System.err.println("db.executeQuery: " + ex.getMessage());
return null;
}
}
//////////////////////////////////////////////
//用於進行add或�?�update,insert,del等的記錄的操�?,
//入口參數:sql語句
//返回 :true,false
//////////////////////////////////////////////
public boolean executeUpdate(String sql) {
boolean bupdate=false;
try{
stmt=cn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_UPDATABLE);
int rowCount = stmt.executeUpdate(sql);
if (rowCount!=0)
bupdate=true;
}
catch(SQLException ex) {
System.err.println("db.executeUpdate: " + ex.getMessage());
}
return bupdate;
}
//////////////////////////////////////////////
//用於進行表結構的操作,creat drop,modify等�??
//入口參數:sql語句
//返回 :true,false
//////////////////////////////////////////////
public boolean executeTable(String sql) {
boolean bupdate=false;
try {
stmt= cn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_UPDATABLE);
System.out.print("對表的操作的sqlis :||"+sql+"||");
stmt.executeUpdate(sql);
bupdate=true;
}
catch(SQLException ex) {
System.err.println("db.executeTable: "+ex.getMessage());
}
return bupdate;
}
//////////////////////////
//返回資料庫的信息
//////////////////////////
public Statement getLWPAIDStatement(){
try{
return cn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_UPDATABLE);
}
catch(java.sql.SQLException e){
System.err.println("getAISPStatement():"+e.getMessage());
return null;
}
}

public DatabaseMetaData getLWPAIDMetaData(){
try{
return cn.getMetaData();
}
catch(java.sql.SQLException e){
System.err.println("getAISPMetaData():"+e.getMessage());
return null;
}
}
public static void main(String args[]){
mySqlDao a=new mySqlDao();
a.Connect("mydb", "localhost");
int b=-100;
ResultSet rs=a.executeSelect("select max(bill_id) from t_bill limit 1");
try{
while(rs.next()){
System.out.println("is in");
b=rs.getInt(1);
}
}catch(Exception e){
e.printStackTrace();
}
System.out.println(b);
// java.util.Date date=new java.util.Date();
// System.out.println(date.toString());
// a.executeTable("insert into t_user values(100,'123','1345')");
// a.executeTable("update t_user set insert_date='"+date.toString()+"' where user_id=100");
a.close();

System.out.print(new pub().asc2unicode("�?!"));
}
}

❸ 誰能幫我做一個VB連接access資料庫的用戶登錄源代碼，要可以注冊的

Private Sub Command1_Click()
Dim A As String
A = App.Path + "\ACCESS文件.mdb"
Adodc1.ConnectionString = "Provider=Microsoft.Jet.OLEDB.4.0;Data Source=" & A & ";Persist Security Info=False"
Adodc1.RecordSource = "SELECT * FROM 用戶表 WHERE 用戶名='" + 用戶名 + "' AND 密碼='" + 密碼 + "'"
Adodc1.Refresh
If OT Adodc1.Recordset.EOF Then
主切面.Show
Me.Hide
Else
MsgBox ("用戶名或密碼錯誤!請重新輸入!")
Me.用戶名 = ""
Me.密碼 = ""
'清空文本框內容
End If
End Sub
' 上面是登陸，把ACCESS建立在VB工程一個文件夾里取相對的路徑
下面是注冊用戶表：
Private Sub Command2_Click()
Dim A As String
A = App.Path + "\ACCESS文件.mdb"
Adodc1.ConnectionString = "Provider=Microsoft.Jet.OLEDB.4.0;Data Source=" & A & ";Persist Security Info=False"
Adodc1.RecordSource = "SELECT * FROM 用戶表 "
Adodc1.Refresh
If OT Adodc1.Recordset.EOF Then
Adodc1.recordset.AddNew
Adodc1.recordset.fields("用戶名")=文本框1
Adodc1.recordset.fields("密碼")=文本框2
.....................
Adodc1.recordset.update
文本框1=""
文本框2=""
......
文本框1.setfocus
ELSE
文本框1=""
文本框2=""
.....
文本框1.setfoucus
end if
end sub