定時讀取資料庫
『壹』 java怎麼實現每天定時讀取文件，然後在寫到資料庫中呢
不是java定時讀取，而是系統調度
比如你寫了一個java程序，這個程序是讀取文件，寫到資料庫中。那麼這個程序怎麼才能定時啟動。是操作系統調度的問題了。不是java的問題。所以要用操作系統的調度。
如果在win伺服器下，可以下一個cmd文件。文件中調用java程序，然後將cmd設置成每天幾點執行
如果是linxu或者unix下，則使用crontab調度。
當然，如果你非要用java程序來調度。那麼這個程序肯定要常駐內存，並且進行睡眠。這種方式沒有意義。
『貳』 怎樣讓spark定時讀資料庫數據
RDD：AResilientDistributedDataset(RDD),thebasicabstractioninSpark.rdd是一個分布式的數據集，數據分散在分布式集群的各台機器上,更像是一張關系型數據表，是一種spark獨有的數據格式吧，這種格式的數據可以使用sqlcontext裡面的函數
『叄』 如何實現每天定時對資料庫的操作
比如你寫了一個java程序，這個程序是讀取文件，寫到資料庫中。那麼這個程序怎麼才能定時啟動。是操作系統調度的問題了。不是java的問題。所以要用操作系統的調度。
如果在win伺服器下，可以下一個cmd文件。文件中調用java程序，然後將cmd設置成每天幾點執行
如果是linxu或者unix下，則使用crontab調度。
當然，如果你非要用java程序來調度。那麼這個程序肯定要常駐內存，並且進行睡眠。這種方式沒有意義。
『肆』 net b/s 結構如何實現定時 訪問資料庫
class Program
{
static void Main(string[] args)
{
//OpenConnection();
//AddRecord();
//DelRecord();
//SoftDelRecord();
//QuertSingle();
//QueryByDataReader();
//QueryByDataAdapter2();
Console.ReadKey();
}
/// <summary>
/// 測試連接通道
/// </summary>
public static void OpenConnection()
{
//1.連接通道的連接字元串
string conStr = @"Persist Security Info=False;Trusted_Connection=True;database=temp;server=(local)";
//2.連接通道對象
SqlConnection conn = new SqlConnection(conStr);
//3.打開通道
conn.Open();
//4.關閉通道
conn.Close();
//5.釋放資源
conn.Dispose();
//測試
Console.WriteLine("******************************");
}
/// <summary>
/// 新增記錄
/// </summary>
public static void AddRecord()
{
//接收新增受影響的行數
int res = -1;
string conStr = @"Persist Security Info=False;Trusted_Connection=True;database=temp;server=(local)";
SqlConnection conn = new SqlConnection(conStr);
//sql語句
string sqlStr = "insert into T_Employee(FNumber,FName,FAge,FSalary) values('ki401','Amy','24','5600.00')";
//新建命令對象
SqlCommand cmd = new SqlCommand(sqlStr, conn);
conn.Open();
//調用方法去資料庫執行sql語句
res = cmd.ExecuteNonQuery(); //此方法用於增刪改（非查詢語句），返回受影響的行數(int)
cmd.Dispose();
conn.Close();
if (res > 0)
{
Console.WriteLine("新增成功！！");
}
else
{
Console.WriteLine("新增失敗！！");
}
conn.Dispose();
}
/// <summary>
/// 刪除記錄
/// </summary>
public static void DelRecord()
{
int res = -1;
string conStr = @"Persist Security Info=False;Trusted_Connection=True;database=temp;server=(local)";
SqlConnection conn = new SqlConnection(conStr);
string sqlStr = "delete T_Employee where fname = 'Amy'";
SqlCommand cmd = new SqlCommand(sqlStr, conn);
conn.Open();
res = cmd.ExecuteNonQuery();
cmd.Dispose();
conn.Close();
if (res > 0)
{
Console.WriteLine("刪除成功！！！");
}
else
{
Console.WriteLine("刪除失敗！！！");
}
conn.Dispose();
}
/// <summary>
/// 軟刪除（更新）記錄
/// 將表中FisDel改為true
/// </summary>
public static void SoftDelRecord()
{
int res = -1;
string conStr = @"Persist Security Info=False;Trusted_Connection=True;database=temp;server=(local)";
SqlConnection conn = new SqlConnection(conStr);
string sqlStr = "update T_Employee set fisdel=1 where fid=1";
SqlCommand cmd = new SqlCommand(sqlStr, conn);
conn.Open();
res = cmd.ExecuteNonQuery();
cmd.Dispose();
conn.Close();
if (res > 0)
{
Console.WriteLine("軟刪除成功！！！");
}
else
{
Console.WriteLine("軟刪除失敗！！！");
}
conn.Dispose();
}
/// <summary>
/// 查詢單個值
/// </summary>
public static void QuertSingle()
{
string conStr = @"Persist Security Info=False;Trusted_Connection=True;database=temp;server=(local)";
SqlConnection conn = new SqlConnection(conStr);
conn.Open();
//string sqlStr = "select count(*) from T_Employee";
string sqlStr = "select * from T_Employee";
SqlCommand cmd = new SqlCommand(sqlStr, conn);
Object obj = cmd.ExecuteScalar(); //調用此方法，獲得查詢語句在資料庫執行後得到的結果集的第一個單元格的值，返回值為Object類型
cmd.Dispose();
conn.Close();
Console.WriteLine(obj.ToString());
conn.Dispose();
}
/// <summary>
/// 查詢多行數據（有兩種方法）
/// </summary>
//方法1 -- DataReader,逐行讀取數據
//DataReader通過連接通道在資料庫維護一個結果集，每次執行Read()方法去資料庫的這個結果集中拿取下一行數據
public static void QueryByDataReader()
{
string conStr = @"Persist Security Info=False;Trusted_Connection=True;database=temp;server=(local)";
SqlConnection conn = new SqlConnection(conStr);
conn.Open();
string sqlStr = "select * from T_Employee";
SqlCommand cmd = new SqlCommand(sqlStr, conn);
SqlDataReader dr = cmd.ExecuteReader(); //調用此方法，還獲得一個SqlDataReader對象
if (dr.HasRows) //如果結果集中有數據行，則返回true
{
while (dr.Read()) //Read方法：如果讀到下一行數據，則返回true，而且本身就等於那一行數據
{
//通過類似索引的方式
//Console.WriteLine(dr[0].ToString() + " " + dr[1].ToString());
//通過列名的方式
//Console.WriteLine(dr["fid"].ToString() + " " + dr["fname"].ToString());
//通過GetString()的方法，必須確保該列內沒有null
Console.WriteLine(dr.GetString(1) + " " + dr.GetDecimal(4));
//GetOrdinal()方法，通過給定列名，獲得在結果集中的索引，返回值為int類型，常與上面GetString()方法聯用
//Console.WriteLine(dr.GetString(dr.GetOrdinal("fnumber")));
//GetValue()方法，給定結果集中的索引，獲得結果集中對應的值，返回值為Object類型
//Console.WriteLine(dr.GetValue(dr.GetOrdinal("fname")).ToString());
}
}
else
{
Console.WriteLine("無數據！！！");
}
//釋放SqlDataReader佔用的資源
dr.Dispose();
cmd.Dispose();
conn.Close();
conn.Dispose();
}
//方法2 -- DataAdapter,一次性取回結果集
public static void QueryByDataAdapter()
{
string conStr = @"Persist Security Info=False;Trusted_Connection=True;database=temp;server=(local)";
SqlConnection conn = new SqlConnection(conStr);
//不需要conn.Open();
string sqlStr = "select * from T_Employee";
//創建DataAdapter對象
SqlDataAdapter da = new SqlDataAdapter(sqlStr, conn);
//創建DataSet（數據集）對象（程序端的臨時資料庫）
DataSet ds = new DataSet();
//調用Fill()方法，填充數據集（先去資料庫結果集，並把結果集復制給數據集）
//給取到的表取別名「table1」
da.Fill(ds,"table1");
//獲取數據集中的第一張表（通過索引）
DataTable dt = ds.Tables[0]; //或ds.Tables["table1"]
//循環數據表中的第一行
for (int i = 0; i < dt.Rows.Count; i++)
{
//將循環到的行給對象dr
DataRow dr = dt.Rows[i];
Console.WriteLine(dr[0].ToString());
}
ds.Dispose();
da.Dispose();
}
/// <summary>
/// 使用DataAdapter填充數據表
/// </summary>
public static void QueryByDataAdapter2()
{
string conStr = @"Persist Security Info=False;Trusted_Connection=True;database=temp;server=(local)";
SqlConnection conn = new SqlConnection(conStr);
//不需要conn.Open();
string sqlStr = "select * from T_Employee";
//創建DataAdapter對象
SqlDataAdapter da = new SqlDataAdapter(sqlStr, conn);
//調用Fill()方法，填充數據表（先去資料庫結果集，並把結果集復制給數據表）
DataTable dt = new DataTable();
da.Fill(dt);
//循環數據表中的第一行
for (int i = 0; i < dt.Rows.Count; i++)
{
//將循環到的行給對象dr
DataRow dr = dt.Rows[i];
Console.WriteLine(dr[0].ToString());
}
dt.Dispose();
da.Dispose();
}
}
『伍』 c#定時讀取資料庫顯示在界面上，然後會很快的一閃一閃的，怎麼消除這種閃爍呢，求大神幫幫忙啊。代碼如下
簡單的辦法是使用vs 組件Timer定時獲取數據,在Timer組件的Tick方法中執行定時取數據的任務
然後根據你獲取的數據繪制頁面圖形，具體繪制那些內容自己處理
『陸』 如何定時從一個資料庫中讀取數據到另外一個資料庫中
如果是sql server 可以用調度定時自動復制或更新到另一個資料庫。
ORECAl等其他大型資料庫類似做法。
小型資料庫的話只能編程了，比如delphi。用時間控制項來實現
『柒』 如何讓程序定時到資料庫中讀取數據
定時任務quartz了解一下。
『捌』 如何實現一個定時任務來對資料庫中的數據進行操作
由於公司的新接得項目要實現一批數據的同步，通過外圍廠商提供的一系列各個系統的webervices介面定時將數據同步到我們開發的共享平台上，由於廠商系統的數據是不斷在變化以及各系統閑忙時的特點，所以定時同步任務的執行必須在時間上能夠動態配置。因此，我們需要動態的從資料庫中獲取配置信息，以改變各個定時間的執行規則，廢話不說了，上代碼：(我利用的是ssh框架直接寫的，框架搭建不再敘述)
1.創建數據表(我用的是MySQL)
[sql] view plain
DROP TABLE IF EXISTS `t_wsdoc`;
CREATE TABLE `t_wsdoc` (
`id` int(11) NOT NULL AUTO_INCREMENT,
`triggername` varchar(50) NOT NULL,
`jobdetailname` varchar(50) N
『玖』 ajax怎麼定時讀取資料庫中的信息
function showLogs()
{
$("#table2").empty(); //這是清空原來的數據
$.ajax({
type:"post",
url:"<%=request.getContextPath()%>/logs/queryLogsInfo.action",
dataType:"json",
success:function(data)
{
for ( var i = 0; i < data.length; i++)
{
$("#table2").append("<tr style='line-height:25px;'>"
+"<td width='5%'>"+data[i].id+"</td>"
+"<td width='5%'>"+data[i].receive+"</td>"
+"<td width='8%'>"+data[i].data+"</td>"
+"<td width='10%'>"+data[i].dataLength+"</td>"
+"</tr>");
}
}
})
}
var t = setInterval("showLogs()", 1000); //隔1秒就查詢一次數據
『拾』 關於JSP定時從資料庫讀取數據並顯示的問題
如果不想ajax，而且，又不想刷新當前頁面，又要實現定時讀取，可以考慮用iframe，在iframe中引入另一個頁面A，讓頁面A進行定時刷新，讀取數據，再讓A頁面修改當前頁面的數據。看你到底想要實現什麼樣的。如果還是不知怎麼實現，可以一起研究研究。